Class SourceTask
public class SourceTask : Task, IDynamicMetaObjectProvider, IJVMBridgeCore, IEquatable<IJVMBridgeBaseInstance>, IDisposable, IJVMBridgeBaseStatic, IJVMBridgeBase, IJVMBridgeBaseInstance, IJVMBridgeDefinition, ITask- Inheritance
-
SourceTask
- Implements
- Derived
- Inherited Members
Constructors
SourceTask()
public SourceTask()SourceTask(IJVMBridgeBaseInitializer)
Initializer used internally by JCOBridge. Do not use directly.
[Obsolete("This public initializer is needed for JCOBridge internal use, other uses can produce unidentible behaviors.")]
public SourceTask(IJVMBridgeBaseInitializer initializer)Parameters
initializerIJVMBridgeBaseInitializer
Fields
DEFAULT
Default SourceTask.TransactionBoundary
public static readonly SourceTask.TransactionBoundary DEFAULTField Value
Properties
BridgeClassName
Java class name to be instantiated
public override string BridgeClassName { get; }Property Value
IsBridgeAbstract
true if the BridgeClassName is an abstract class, i.e. cannot be created an instance
public override bool IsBridgeAbstract { get; }Property Value
IsBridgeCloseable
true if the BridgeClassName implements java.lang.AutoCloseable
public override bool IsBridgeCloseable { get; }Property Value
IsBridgeInterface
true if the BridgeClassName is an interface, i.e. does not have any public constructor
public override bool IsBridgeInterface { get; }Property Value
IsBridgeStatic
true if the BridgeClassName is a static class, i.e. does not have any public constructor
public override bool IsBridgeStatic { get; }Property Value
TRANSACTION_BOUNDARY_CONFIG
public static String TRANSACTION_BOUNDARY_CONFIG { get; set; }Property Value
Methods
Commit()
public void Commit()Exceptions
CommitRecord(SourceRecord, RecordMetadata)
public void CommitRecord(SourceRecord arg0, RecordMetadata arg1)Parameters
arg0SourceRecordarg1RecordMetadata
Exceptions
CreatePoolableInstance()
HPA initializer for SourceTask()
public static SourceTask CreatePoolableInstance()Returns
Initialize(SourceTaskContext)
public void Initialize(SourceTaskContext arg0)Parameters
Poll()
public List<SourceRecord> Poll()Returns
Exceptions
Start(Map<String, String>)
public void Start(Map<String, String> arg0)Parameters
Stop()
public void Stop()