Package com.snowflake.connectors.taskreactor.worker.ingestion

Class SimpleIngestionWorkItem<I,M,C,D>

java.lang.Object

com.snowflake.connectors.taskreactor.worker.ingestion.SimpleIngestionWorkItem<I,M,C,D>

Type Parameters:

I - resource id class, containing properties which identify the resource in the source system

M - resource metadata class, containing additional properties which identify the resource in the source system. The properties can be fetched automatically or calculated by the connector

C - custom ingestion configuration class, containing custom ingestion properties

D - destination configuration class, containing properties describing where the ingested data should be stored

public class SimpleIngestionWorkItem<I,M,C,D>
extends Object

A payload of a work item containing a data needed by a single simple ingestion task. Parameters are taken from the @ResourceIngestionDefinition class implementation.

Constructor Summary

Constructors

Constructor	Description
SimpleIngestionWorkItem()	Creates an empty SimpleIngestionWorkItem.
SimpleIngestionWorkItem(String id, String processId, String processType, String resourceIngestionDefinitionId, String ingestionConfigurationId, I resourceId, String ingestionStrategy, M resourceMetadata, C customConfig, D destination, Variant metadata)	Creates a new SimpleIngestionWorkItem.

Method Summary

Modifier and Type	Method	Description
boolean	equals(Object o)
C	getCustomConfig()	Returns the custom configuration.
D	getDestination()	Returns the destination.
String	getId()	Returns the id of the ingestion process.
String	getIngestionConfigurationId()	Returns the ingestion configuration id.
String	getIngestionStrategy()	Returns the ingestion strategy.
Variant	getMetadata()	Returns the process metadata.
String	getProcessId()	Returns the ingestion process id.
String	getProcessType()	Returns the ingestion process type.
I	getResourceId()	Returns the resource id.
String	getResourceIngestionDefinitionId()	Returns the resource ingestion definition id.
M	getResourceMetadata()	Returns the resource metadata.
int	hashCode()
String	toString()

Methods inherited from class java.lang.Object

clone, finalize, getClass, notify, notifyAll, wait, wait, wait

Constructor Detail

SimpleIngestionWorkItem

public SimpleIngestionWorkItem()

Creates an empty SimpleIngestionWorkItem.

This constructor is used by the reflection-based mapping process and should not be used for any other purpose.

SimpleIngestionWorkItem

public SimpleIngestionWorkItem(@Deprecated
                               String id,
                               String processId,
                               String processType,
                               String resourceIngestionDefinitionId,
                               String ingestionConfigurationId,
                               I resourceId,
                               String ingestionStrategy,
                               M resourceMetadata,
                               C customConfig,
                               D destination,
                               Variant metadata)

Creates a new SimpleIngestionWorkItem.

Parameters:

id - ingestion process id - deprecated, use processId instead

processId - ingestion process id

processType - ingestion process type

resourceIngestionDefinitionId - resource ingestion definition id

ingestionConfigurationId - ingestion configuration id

resourceId - properties which identify the resource in the source system

ingestionStrategy - ingestion strategy

resourceMetadata - resource metadata

customConfig - custom ingestion properties

destination - properties describing where the ingested data should be stored

metadata - process metadata

Method Detail

getId

public String getId()

Returns the id of the ingestion process.

Returns:

id of the ingestion process

getProcessId

public String getProcessId()

Returns the ingestion process id.

Returns:

ingestion process id

getProcessType

public String getProcessType()

Returns the ingestion process type.

Returns:

ingestion process type

getResourceIngestionDefinitionId

public String getResourceIngestionDefinitionId()

Returns the resource ingestion definition id.

Returns:

resource ingestion definition id

getIngestionConfigurationId

public String getIngestionConfigurationId()

Returns the ingestion configuration id.

Returns:

ingestion configuration id

getResourceId

public I getResourceId()

Returns the resource id.

Returns:

resource id

getIngestionStrategy

public String getIngestionStrategy()

Returns the ingestion strategy.

Returns:

ingestion strategy

getResourceMetadata

public M getResourceMetadata()

Returns the resource metadata.

Returns:

resource metadata

getDestination

public D getDestination()

Returns the destination.

Returns:

destination

getCustomConfig

public C getCustomConfig()

Returns the custom configuration.

Returns:

custom configuration

getMetadata

public Variant getMetadata()

Returns the process metadata.

Returns:

process metadata

equals

public boolean equals(Object o)

Overrides:

equals in class Object

hashCode

public int hashCode()

Overrides:

hashCode in class Object

toString

public String toString()

Overrides:

toString in class Object