Table of Contents

Class ConnectUtils

Namespace
Org.Apache.Kafka.Connect.Util
Assembly
MASES.KNet.dll
public class ConnectUtils : JVMBridgeBase<ConnectUtils>, IDynamicMetaObjectProvider, IJVMBridgeCore, IDisposable, IJVMBridgeBaseStatic, IJVMBridgeBase, IJVMBridgeDefinition
Inheritance
JVMBridgeBase
JVMBridgeBase<ConnectUtils>
ConnectUtils
Implements
IJVMBridgeCore
IJVMBridgeBaseStatic
IJVMBridgeBase
IJVMBridgeDefinition
Inherited Members
JVMBridgeBase<ConnectUtils>.IsAssignableFrom(IJavaType)
JVMBridgeBase<ConnectUtils>.IsAssignableFrom<T>()
JVMBridgeBase<ConnectUtils>.Execute<T>(params T[])
JVMBridgeBase<ConnectUtils>.DynBridgeClazz
JVMBridgeBase<ConnectUtils>.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

ConnectUtils()

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

public ConnectUtils()

ConnectUtils(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

public ConnectUtils(params object[] args)

Parameters

args object[]

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

Methods

CheckAndConvertTimestamp(Long)

public static Long CheckAndConvertTimestamp(Long arg0)

Parameters

arg0 Long

Long

Returns

Long

Long

ClassName(object)

public static String ClassName(object arg0)

Parameters

arg0 object

object

Returns

String

String

CombineCollections<I>(Collection<Collection<I>>)

public static List<I> CombineCollections<I>(Collection<Collection<I>> arg0)

Parameters

arg0 Collection<Collection<I>>

Collection

Returns

List<I>

List

Type Parameters

I

CombineCollections<T, I>(Collection<I>, Function<I, Collection<T>>)

public static List<T> CombineCollections<T, I>(Collection<I> arg0, Function<I, Collection<T>> arg1)

Parameters

arg0 Collection<I>

Collection

arg1 Function<I, Collection<T>>

Function

Returns

List<T>

List

Type Parameters

T
I

CombineCollections<C, I, T>(Collection<I>, Function<I, Collection<T>>, Collector<T, object, C>)

public static C CombineCollections<C, I, T>(Collection<I> arg0, Function<I, Collection<T>> arg1, Collector<T, object, C> arg2)

Parameters

arg0 Collection<I>

Collection

arg1 Function<I, Collection<T>>

Function

arg2 Collector<T, object, C>

Collector

Returns

C

C

Type Parameters

C
I
T

EnsureProperty<Arg0objectSuperJava_Lang_String>(Map<String, Arg0objectSuperJava_Lang_String>, String, String, String, bool)

public static void EnsureProperty<Arg0objectSuperJava_Lang_String>(Map<String, Arg0objectSuperJava_Lang_String> arg0, String arg1, String arg2, String arg3, bool arg4) where Arg0objectSuperJava_Lang_String : String

Parameters

arg0 Map<String, Arg0objectSuperJava_Lang_String>

Map

arg1 String

String

arg2 String

String

arg3 String

String

arg4 bool

bool

Type Parameters

Arg0objectSuperJava_Lang_String

String

IsSinkConnector(Connector)

public static bool IsSinkConnector(Connector arg0)

Parameters

arg0 Connector

Connector

Returns

bool

bool

IsSourceConnector(Connector)

public static bool IsSourceConnector(Connector arg0)

Parameters

arg0 Connector

Connector

Returns

bool

bool

MaybeWrap(JVMBridgeException, String)

public static ConnectException MaybeWrap(JVMBridgeException arg0, String arg1)

Parameters

arg0 JVMBridgeException

Throwable

arg1 String

String

Returns

ConnectException

ConnectException

PatchConfig(Map<String, String>, Map<String, String>)

public static Map<String, String> PatchConfig(Map<String, String> arg0, Map<String, String> arg1)

Parameters

arg0 Map<String, String>

Map

arg1 Map<String, String>

Map

Returns

Map<String, String>

Map

TransformValues<K, O, I>(Map<K, I>, Function<I, O>)

public static Map<K, O> TransformValues<K, O, I>(Map<K, I> arg0, Function<I, O> arg1)

Parameters

arg0 Map<K, I>

Map

arg1 Function<I, O>

Function

Returns

Map<K, O>

Map

Type Parameters

K
O
I