Package com.logicalclocks.hsfs

Class OnlineIngestion

java.lang.Object

com.logicalclocks.hsfs.metadata.RestDto<OnlineIngestion>

com.logicalclocks.hsfs.OnlineIngestion

public class OnlineIngestion
extends RestDto<OnlineIngestion>

Field Summary

Fields

Modifier and Type	Field	Description
protected static final org.slf4j.Logger	LOGGER

Fields inherited from class com.logicalclocks.hsfs.metadata.RestDto

count, items

Constructor Summary

Constructors

Constructor	Description
OnlineIngestion(Long numEntries)

Method Summary

Modifier and Type	Method	Description
void	refresh()
void	waitForCompletion(int timeout, int period)	Blocks until every entry of this ingestion is ingested or timeout seconds have passed.

Methods inherited from class com.logicalclocks.hsfs.metadata.RestDto

getCount, getItems, setCount, setItems

Methods inherited from class java.lang.Object

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

Field Details

LOGGER

protected static final org.slf4j.Logger LOGGER

Constructor Details

OnlineIngestion

public OnlineIngestion(Long numEntries)

Method Details

refresh

public void refresh()
             throws FeatureStoreException,
IOException

Throws:

FeatureStoreException

IOException

waitForCompletion

public void waitForCompletion(int timeout,
 int period)
                       throws InterruptedException,
FeatureStoreException,
IOException

Blocks until every entry of this ingestion is ingested or timeout seconds have passed. A timeout of 0 waits until every entry is ingested; an ingestion without an entry count cannot tell when that is, so with 0 its wait does not end on its own, and it logs a warning when it starts.

Throws:

InterruptedException

FeatureStoreException

IOException