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 and Description
protected static org.slf4j.Logger	LOGGER

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

count, items

Constructor Summary

Constructors

Constructor and Description
OnlineIngestion(long numEntries)

Method Summary

Modifier and Type	Method and Description
void	refresh()
void	waitForCompletion(int timeout, int period)

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 Detail

LOGGER

protected static final org.slf4j.Logger LOGGER

Constructor Detail

OnlineIngestion

public OnlineIngestion(long numEntries)

Method Detail

refresh

public void refresh()
             throws FeatureStoreException,
                    IOException

Throws:

FeatureStoreException

IOException

waitForCompletion

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

Throws:

InterruptedException

FeatureStoreException

IOException