Interface IKNetPredicate

Namespace

MASES.KNet.Connect.Transforms.Predicates

Assembly

MASES.KNet.dll

Specific implementation of IConnector to support KNet Connect SDK

public interface IKNetPredicate : IPredicate, IVersion

Inherited Members

IPredicate.Test(ConnectRecord)

IPredicate.Configure(Map<String, object>)

IPredicate.Close()

IPredicate.Config()

IPredicate.ToStringPredicate()

IVersion.Version()

Methods

Configure(IKNetConfigurationFromMap)

Implement the method to execute the start action

void Configure(IKNetConfigurationFromMap configuration)

Parameters

configuration IKNetConfigurationFromMap

The IKNetConfigurationFromMap to access the properties returned from Apache Kafka Connect framework: the Properties contains the same info from configuration file.

Test(SinkRecord)

Implements the behavior of Test(ConnectRecord) for record

bool Test(SinkRecord record)

Parameters

record SinkRecord

The SinkRecord to test

Returns

bool

Follow specifications of Test(ConnectRecord)

Remarks

If the method is overridden never invoke the base method othrwise an exception is raised within the JVM.

Test(SourceRecord)

Implements the behavior of Test(ConnectRecord) for record

bool Test(SourceRecord record)

Parameters

record SourceRecord

The SourceRecord to test

Returns

bool

Follow specifications of Test(ConnectRecord)

Remarks

If the method is overridden never invoke the base method othrwise an exception is raised within the JVM.