public class EsTap extends Tap<java.lang.Object,java.lang.Object,java.lang.Object>
| Constructor and Description |
|---|
EsTap(java.lang.String resource) |
EsTap(java.lang.String resource,
Fields fields) |
EsTap(java.lang.String host,
int port,
java.lang.String resource) |
EsTap(java.lang.String host,
int port,
java.lang.String resource,
Fields fields) |
EsTap(java.lang.String host,
int port,
java.lang.String resource,
java.lang.String query) |
EsTap(java.lang.String host,
int port,
java.lang.String resource,
java.lang.String query,
Fields fields) |
EsTap(java.lang.String host,
int port,
java.lang.String resource,
java.lang.String query,
Fields fields,
java.util.Properties tapSettings) |
EsTap(java.lang.String resource,
java.lang.String query) |
EsTap(java.lang.String resource,
java.lang.String query,
Fields fields) |
| Modifier and Type | Method and Description |
|---|---|
boolean |
createResource(java.lang.Object conf) |
boolean |
deleteResource(java.lang.Object conf) |
void |
flowConfInit(Flow<java.lang.Object> flow) |
java.lang.String |
getIdentifier() |
long |
getModifiedTime(java.lang.Object conf) |
boolean |
isEquivalentTo(FlowElement element) |
boolean |
isSink() |
boolean |
isSource() |
TupleEntryIterator |
openForRead(FlowProcess<java.lang.Object> flowProcess,
java.lang.Object input) |
TupleEntryCollector |
openForWrite(FlowProcess<java.lang.Object> flowProcess,
java.lang.Object output) |
boolean |
resourceExists(java.lang.Object conf) |
void |
sinkConfInit(FlowProcess<java.lang.Object> flowProcess,
java.lang.Object conf) |
void |
sourceConfInit(FlowProcess<java.lang.Object> flowProcess,
java.lang.Object conf) |
java.lang.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(java.lang.String resource)
public EsTap(java.lang.String resource,
java.lang.String query)
public EsTap(java.lang.String host,
int port,
java.lang.String resource)
public EsTap(java.lang.String host,
int port,
java.lang.String resource,
Fields fields)
public EsTap(java.lang.String host,
int port,
java.lang.String resource,
java.lang.String query)
public EsTap(java.lang.String resource,
Fields fields)
public EsTap(java.lang.String resource,
java.lang.String query,
Fields fields)
public EsTap(java.lang.String host,
int port,
java.lang.String resource,
java.lang.String query,
Fields fields)
public EsTap(java.lang.String host,
int port,
java.lang.String resource,
java.lang.String query,
Fields fields,
java.util.Properties tapSettings)
public void flowConfInit(Flow<java.lang.Object> flow)
flowConfInit in class Tap<java.lang.Object,java.lang.Object,java.lang.Object>public boolean isSink()
public boolean isSource()
public java.lang.String getIdentifier()
getIdentifier in class Tap<java.lang.Object,java.lang.Object,java.lang.Object>public void sourceConfInit(FlowProcess<java.lang.Object> flowProcess, java.lang.Object conf)
sourceConfInit in class Tap<java.lang.Object,java.lang.Object,java.lang.Object>public void sinkConfInit(FlowProcess<java.lang.Object> flowProcess, java.lang.Object conf)
sinkConfInit in class Tap<java.lang.Object,java.lang.Object,java.lang.Object>public TupleEntryIterator openForRead(FlowProcess<java.lang.Object> flowProcess, java.lang.Object input) throws java.io.IOException
openForRead in class Tap<java.lang.Object,java.lang.Object,java.lang.Object>java.io.IOExceptionpublic TupleEntryCollector openForWrite(FlowProcess<java.lang.Object> flowProcess, java.lang.Object output) throws java.io.IOException
openForWrite in class Tap<java.lang.Object,java.lang.Object,java.lang.Object>java.io.IOExceptionpublic boolean createResource(java.lang.Object conf)
throws java.io.IOException
createResource in class Tap<java.lang.Object,java.lang.Object,java.lang.Object>java.io.IOExceptionpublic boolean deleteResource(java.lang.Object conf)
throws java.io.IOException
deleteResource in class Tap<java.lang.Object,java.lang.Object,java.lang.Object>java.io.IOExceptionpublic boolean resourceExists(java.lang.Object conf)
throws java.io.IOException
resourceExists in class Tap<java.lang.Object,java.lang.Object,java.lang.Object>java.io.IOExceptionpublic long getModifiedTime(java.lang.Object conf)
throws java.io.IOException
getModifiedTime in class Tap<java.lang.Object,java.lang.Object,java.lang.Object>java.io.IOExceptionpublic boolean isEquivalentTo(FlowElement element)
isEquivalentTo in interface FlowElementisEquivalentTo in class Tap<java.lang.Object,java.lang.Object,java.lang.Object>