Package com.snowflake.connectors.application.ingestion.process

Class InMemoryIngestionProcessRepository

java.lang.Object

com.snowflake.connectors.application.ingestion.process.InMemoryIngestionProcessRepository

All Implemented Interfaces:

com.snowflake.connectors.application.ingestion.process.CrudIngestionProcessRepository, com.snowflake.connectors.application.ingestion.process.IngestionProcessRepository

public class InMemoryIngestionProcessRepository
extends Object
implements com.snowflake.connectors.application.ingestion.process.IngestionProcessRepository, com.snowflake.connectors.application.ingestion.process.CrudIngestionProcessRepository

In memory implementation of IngestionProcessRepository and CrudIngestionProcessRepository

Constructor Summary

Constructors

Constructor	Description
InMemoryIngestionProcessRepository()

Method Summary

Modifier and Type	Method	Description
void	clear()	Clears the repository.
String	createProcess(String resourceIngestionDefinitionId, String ingestionConfigurationId, String type, String status, Variant metadata)
void	endProcess(String processId)
void	endProcess(String resourceIngestionDefinitionId, String ingestionConfigurationId, String type)
Optional<com.snowflake.connectors.application.ingestion.process.IngestionProcess>	fetch(String processId)
List<com.snowflake.connectors.application.ingestion.process.IngestionProcess>	fetchAll(String status)
List<com.snowflake.connectors.application.ingestion.process.IngestionProcess>	fetchAll(String resourceIngestionDefinitionId, String ingestionConfigurationId, String type)
List<com.snowflake.connectors.application.ingestion.process.IngestionProcess>	fetchAll(List<String> resourceIngestionDefinitionIds)
List<com.snowflake.connectors.application.ingestion.process.IngestionProcess>	fetchAllActive(String resourceIngestionDefinitionId)
Optional<com.snowflake.connectors.application.ingestion.process.IngestionProcess>	fetchLastFinished(String resourceIngestionDefinitionId, String ingestionConfigurationId, String type)
Map<String,com.snowflake.connectors.application.ingestion.process.IngestionProcess>	getRepository()	Returns repository.
void	save(com.snowflake.connectors.application.ingestion.process.IngestionProcess ingestionProcess)
void	save(Collection<com.snowflake.connectors.application.ingestion.process.IngestionProcess> ingestionProcesses)
void	updateStatus(String processId, String status)
void	updateStatus(String resourceIngestionDefinitionId, String ingestionConfigurationId, String type, String status)

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Detail

InMemoryIngestionProcessRepository

public InMemoryIngestionProcessRepository()

Method Detail

createProcess

public String createProcess(String resourceIngestionDefinitionId,
                            String ingestionConfigurationId,
                            String type,
                            String status,
                            Variant metadata)

Specified by:

createProcess in interface com.snowflake.connectors.application.ingestion.process.IngestionProcessRepository

updateStatus

public void updateStatus(String processId,
                         String status)

Specified by:

updateStatus in interface com.snowflake.connectors.application.ingestion.process.IngestionProcessRepository

updateStatus

public void updateStatus(String resourceIngestionDefinitionId,
                         String ingestionConfigurationId,
                         String type,
                         String status)

Specified by:

updateStatus in interface com.snowflake.connectors.application.ingestion.process.IngestionProcessRepository

endProcess

public void endProcess(String processId)

Specified by:

endProcess in interface com.snowflake.connectors.application.ingestion.process.IngestionProcessRepository

endProcess

public void endProcess(String resourceIngestionDefinitionId,
                       String ingestionConfigurationId,
                       String type)

Specified by:

endProcess in interface com.snowflake.connectors.application.ingestion.process.IngestionProcessRepository

fetch

public Optional<com.snowflake.connectors.application.ingestion.process.IngestionProcess> fetch(String processId)

Specified by:

fetch in interface com.snowflake.connectors.application.ingestion.process.CrudIngestionProcessRepository

Specified by:

fetch in interface com.snowflake.connectors.application.ingestion.process.IngestionProcessRepository

fetchLastFinished

public Optional<com.snowflake.connectors.application.ingestion.process.IngestionProcess> fetchLastFinished(String resourceIngestionDefinitionId,
                                                                                                           String ingestionConfigurationId,
                                                                                                           String type)

Specified by:

fetchLastFinished in interface com.snowflake.connectors.application.ingestion.process.IngestionProcessRepository

fetchAll

public List<com.snowflake.connectors.application.ingestion.process.IngestionProcess> fetchAll(String resourceIngestionDefinitionId,
                                                                                              String ingestionConfigurationId,
                                                                                              String type)

Specified by:

fetchAll in interface com.snowflake.connectors.application.ingestion.process.IngestionProcessRepository

fetchAll

public List<com.snowflake.connectors.application.ingestion.process.IngestionProcess> fetchAll(List<String> resourceIngestionDefinitionIds)

Specified by:

fetchAll in interface com.snowflake.connectors.application.ingestion.process.CrudIngestionProcessRepository

fetchAll

public List<com.snowflake.connectors.application.ingestion.process.IngestionProcess> fetchAll(String status)

Specified by:

fetchAll in interface com.snowflake.connectors.application.ingestion.process.CrudIngestionProcessRepository

fetchAllActive

public List<com.snowflake.connectors.application.ingestion.process.IngestionProcess> fetchAllActive(String resourceIngestionDefinitionId)

Specified by:

fetchAllActive in interface com.snowflake.connectors.application.ingestion.process.IngestionProcessRepository

save

public void save(com.snowflake.connectors.application.ingestion.process.IngestionProcess ingestionProcess)

Specified by:

save in interface com.snowflake.connectors.application.ingestion.process.CrudIngestionProcessRepository

save

public void save(Collection<com.snowflake.connectors.application.ingestion.process.IngestionProcess> ingestionProcesses)

Specified by:

save in interface com.snowflake.connectors.application.ingestion.process.CrudIngestionProcessRepository

clear

public void clear()

Clears the repository.

getRepository

public Map<String,com.snowflake.connectors.application.ingestion.process.IngestionProcess> getRepository()

Returns repository.

Returns:

collection for repository