public class EsTap extends Tap<Object,Object,Object>
| Constructor and Description |
|---|
EsTap(String resource) |
EsTap(String resource,
Fields fields) |
EsTap(String host,
int port,
String resource) |
EsTap(String host,
int port,
String resource,
Fields fields) |
EsTap(String host,
int port,
String resource,
String query) |
EsTap(String host,
int port,
String resource,
String query,
Fields fields) |
EsTap(String host,
int port,
String resource,
String query,
Fields fields,
Properties tapSettings) |
EsTap(String resource,
String query) |
EsTap(String resource,
String query,
Fields fields) |
| Modifier and Type | Method and Description |
|---|---|
boolean |
createResource(Object conf) |
boolean |
deleteResource(Object conf) |
void |
flowConfInit(Flow<Object> flow) |
String |
getIdentifier() |
long |
getModifiedTime(Object conf) |
boolean |
isEquivalentTo(FlowElement element) |
boolean |
isSink() |
boolean |
isSource() |
TupleEntryIterator |
openForRead(FlowProcess<Object> flowProcess,
Object input) |
TupleEntryCollector |
openForWrite(FlowProcess<Object> flowProcess,
Object output) |
boolean |
resourceExists(Object conf) |
void |
sinkConfInit(FlowProcess<Object> flowProcess,
Object conf) |
void |
sourceConfInit(FlowProcess<Object> flowProcess,
Object conf) |
String |
toString() |
commitResource, createResource, deleteResource, equals, getConfigDef, getFullIdentifier, getFullIdentifier, getModifiedTime, getScheme, getSinkFields, getSinkMode, getSourceFields, getStepConfigDef, getTrace, hasConfigDef, hashCode, hasStepConfigDef, id, isKeep, isReplace, isTemporary, isUpdate, openForRead, openForWrite, outgoingScopeFor, presentSinkFields, presentSourceFields, resolveIncomingOperationArgumentFields, resolveIncomingOperationPassThroughFields, resourceExists, retrieveSinkFields, retrieveSourceFields, rollbackResource, setScheme, tapspublic EsTap(String resource)
public EsTap(String host, int port, String resource, String query, Fields fields, Properties tapSettings)
public void flowConfInit(Flow<Object> flow)
flowConfInit in class Tap<Object,Object,Object>public String getIdentifier()
getIdentifier in class Tap<Object,Object,Object>public void sourceConfInit(FlowProcess<Object> flowProcess, Object conf)
sourceConfInit in class Tap<Object,Object,Object>public void sinkConfInit(FlowProcess<Object> flowProcess, Object conf)
sinkConfInit in class Tap<Object,Object,Object>public TupleEntryIterator openForRead(FlowProcess<Object> flowProcess, Object input) throws IOException
openForRead in class Tap<Object,Object,Object>IOExceptionpublic TupleEntryCollector openForWrite(FlowProcess<Object> flowProcess, Object output) throws IOException
openForWrite in class Tap<Object,Object,Object>IOExceptionpublic boolean createResource(Object conf) throws IOException
createResource in class Tap<Object,Object,Object>IOExceptionpublic boolean deleteResource(Object conf) throws IOException
deleteResource in class Tap<Object,Object,Object>IOExceptionpublic boolean resourceExists(Object conf) throws IOException
resourceExists in class Tap<Object,Object,Object>IOExceptionpublic long getModifiedTime(Object conf) throws IOException
getModifiedTime in class Tap<Object,Object,Object>IOExceptionpublic boolean isEquivalentTo(FlowElement element)
isEquivalentTo in interface FlowElementisEquivalentTo in class Tap<Object,Object,Object>