T
- the type for entries that are being ingestedpublic class IngestOptions<T> extends Object
Modifier and Type | Class and Description |
---|---|
static interface |
IngestOptions.Builder<T>
A Builder to create IngestOptions
|
static interface |
IngestOptions.IngestCallback<T>
An interface to get callbacks of ingest
|
Constructor and Description |
---|
IngestOptions(LocalFileIngestPlugin<T> format,
int threads,
VisibilityHandler visibilityHandler,
String[] fileExtensions,
java.util.function.Predicate<T> filter,
java.util.function.Function<T,T> transform,
IngestOptions.IngestCallback<T> callback,
Properties properties)
Use the Builder to construct instead of this constructor.
|
Modifier and Type | Method and Description |
---|---|
IngestOptions.IngestCallback<T> |
getCallback() |
String[] |
getFileExtensions() |
java.util.function.Predicate<T> |
getFilter() |
LocalFileIngestPlugin<T> |
getFormat() |
Properties |
getProperties() |
int |
getThreads() |
java.util.function.Function<T,T> |
getTransform() |
VisibilityHandler |
getVisibilityHandler() |
static <T> IngestOptions.Builder<T> |
newBuilder()
get a default implementation of this builder
|
public IngestOptions(LocalFileIngestPlugin<T> format, int threads, VisibilityHandler visibilityHandler, String[] fileExtensions, java.util.function.Predicate<T> filter, java.util.function.Function<T,T> transform, IngestOptions.IngestCallback<T> callback, Properties properties)
format
- the ingest format pluginthreads
- number of threadsglobalVisibility
- visibility applied to all entriesfileExtensions
- an array of acceptable file extensionsfilter
- a function to filter entries prior to ingesttransform
- a function to transform entries prior to ingestcallback
- a callback to get entries ingested and their insertion ID(s) in GeoWaveproperties
- properties used for particular URL handlerspublic static <T> IngestOptions.Builder<T> newBuilder()
public LocalFileIngestPlugin<T> getFormat()
public int getThreads()
public VisibilityHandler getVisibilityHandler()
public String[] getFileExtensions()
public java.util.function.Predicate<T> getFilter()
public java.util.function.Function<T,T> getTransform()
public IngestOptions.IngestCallback<T> getCallback()
public Properties getProperties()
Copyright © 2013–2022. All rights reserved.