Table of Contents

Class SourceTask

Namespace
Org.Apache.Kafka.Connect.Source
Assembly
MASES.KNet.dll
public class SourceTask : Task, IDynamicMetaObjectProvider, IJVMBridgeCore, IDisposable, IJVMBridgeBaseStatic, IJVMBridgeBase, IJVMBridgeDefinition, ITask
Inheritance
JVMBridgeBase
JVMBridgeBase<Task>
SourceTask
Implements
IJVMBridgeCore
IJVMBridgeBaseStatic
IJVMBridgeBase
IJVMBridgeDefinition
Derived
Inherited Members
JVMBridgeBase<Task>.IsAssignableFrom(IJavaType)
JVMBridgeBase<Task>.IsAssignableFrom<T>()
JVMBridgeBase<Task>.Execute<T>(params T[])
JVMBridgeBase<Task>.DynBridgeClazz
JVMBridgeBase<Task>.BridgeClazz
JVMBridgeBase.RuntimeClassNameOf<T>()
JVMBridgeBase.ClassNameOf<T>()
JVMBridgeBase.ClassOf<T>()
JVMBridgeBase.WrapsDirect<TNewClass>(IJavaObject)
JVMBridgeBase.Wraps<TNewClass>(IJavaObject)
JVMBridgeBase.Wraps<TNewClass, TReturn>(IJavaObject)
JVMBridgeBase.Wraps<TNewClass, TReturn, TConverter>(IJavaObject)
JVMBridgeBase.MonitorEnter()
JVMBridgeBase.MonitorExit()
JVMBridgeBase.IsInstanceOf(IJavaType)
JVMBridgeBase.IsInstanceOf<T>()
JVMBridgeBase.RuntimeIsInstanceOf<T>()
JVMBridgeBase.CastTo<TNewClass>()
JVMBridgeBase.CastDirect<TNewClass>()
JVMBridgeBase.Dispose()
JVMBridgeBase.ToString()
JVMBridgeBase.GetHashCode()
JVMBridgeBase.Notify()
JVMBridgeBase.NotifyAll()
JVMBridgeBase.Wait()
JVMBridgeBase.DynBridgeInstance
JVMBridgeBase.BridgeInstance
JVMBridgeBase.IsBridgeListener

Constructors

SourceTask()

Default constructor: even if the corresponding Java class does not have one, it is mandatory for JCOBridge

[Obsolete("SourceTask class represents, in .NET, an instance of a JVM interface or abstract class. This public initializer is needed for JCOBridge internal use, other uses can produce unidentible behaviors.")]
public SourceTask()

SourceTask(params object[])

Generic constructor: it is useful for JCOBridge when there is a derived class which needs to pass arguments to the highest JVMBridgeBase class

[Obsolete("SourceTask class represents, in .NET, an instance of a JVM interface or abstract class. This public initializer is needed for JCOBridge internal use, other uses can produce unidentible behaviors.")]
public SourceTask(params object[] args)

Parameters

args object[]

Fields

DEFAULT

public static readonly SourceTask.TransactionBoundary DEFAULT

Field Value

SourceTask.TransactionBoundary

Properties

BridgeClassName

public override string BridgeClassName { get; }

Property Value

string

IsBridgeAbstract

public override bool IsBridgeAbstract { get; }

Property Value

bool

IsBridgeCloseable

public override bool IsBridgeCloseable { get; }

Property Value

bool

IsBridgeInterface

public override bool IsBridgeInterface { get; }

Property Value

bool

IsBridgeStatic

public override bool IsBridgeStatic { get; }

Property Value

bool

TRANSACTION_BOUNDARY_CONFIG

public static String TRANSACTION_BOUNDARY_CONFIG { get; }

Property Value

String

Methods

Commit()

public void Commit()

Exceptions

InterruptedException

CommitRecord(SourceRecord, RecordMetadata)

public void CommitRecord(SourceRecord arg0, RecordMetadata arg1)

Parameters

arg0 SourceRecord

SourceRecord

arg1 RecordMetadata

RecordMetadata

Exceptions

InterruptedException

Initialize(SourceTaskContext)

public void Initialize(SourceTaskContext arg0)

Parameters

arg0 SourceTaskContext

SourceTaskContext

Poll()

public List<SourceRecord> Poll()

Returns

List<SourceRecord>

List

Exceptions

InterruptedException

Start(Map<String, String>)

public void Start(Map<String, String> arg0)

Parameters

arg0 Map<String, String>

Map

Stop()

public void Stop()