@Deprecated public class EsTap extends Tap<Object,Object,Object>
| Constructor and Description |
|---|
EsTap(String resource)
Deprecated.
|
EsTap(String resource,
Fields fields)
Deprecated.
|
EsTap(String host,
int port,
String resource)
Deprecated.
|
EsTap(String host,
int port,
String resource,
Fields fields)
Deprecated.
|
EsTap(String host,
int port,
String resource,
String query)
Deprecated.
|
EsTap(String host,
int port,
String resource,
String query,
Fields fields)
Deprecated.
|
EsTap(String host,
int port,
String resource,
String query,
Fields fields,
Properties tapSettings)
Deprecated.
|
EsTap(String resource,
String query)
Deprecated.
|
EsTap(String resource,
String query,
Fields fields)
Deprecated.
|
| Modifier and Type | Method and Description |
|---|---|
boolean |
createResource(Object conf)
Deprecated.
|
boolean |
deleteResource(Object conf)
Deprecated.
|
void |
flowConfInit(Flow<Object> flow)
Deprecated.
|
String |
getIdentifier()
Deprecated.
|
long |
getModifiedTime(Object conf)
Deprecated.
|
static void |
initCredentials(Properties flowConnectorProperties)
Deprecated.
If Kerberos Security is enabled for Hadoop and Elasticsearch, this function will securely contact Elasticsearch
using Kerberos to authenticate, and retrieve a delegation token for use by worker processes on the cluster.
|
boolean |
isEquivalentTo(FlowElement element)
Deprecated.
|
boolean |
isSink()
Deprecated.
|
boolean |
isSource()
Deprecated.
|
TupleEntryIterator |
openForRead(FlowProcess<Object> flowProcess,
Object input)
Deprecated.
|
TupleEntryCollector |
openForWrite(FlowProcess<Object> flowProcess,
Object output)
Deprecated.
|
boolean |
resourceExists(Object conf)
Deprecated.
|
void |
sinkConfInit(FlowProcess<Object> flowProcess,
Object conf)
Deprecated.
|
void |
sourceConfInit(FlowProcess<Object> flowProcess,
Object conf)
Deprecated.
|
String |
toString()
Deprecated.
|
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 boolean isSource()
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>public String toString()
public static void initCredentials(Properties flowConnectorProperties)
flowConnectorProperties - The runtime properties for the Hadoop Flow Connector. Hadoop settings will also be loaded from
the classpath.