Interface InstanceStreamService
-
@Deprecated public interface InstanceStreamService
Deprecated.This class is a temporary solution for the problem with Snowflake Streams staleness. It will be most probably deleted in the future versions of the SDK - be aware of it when using it.
-
-
Method Summary
All Methods Static Methods Instance Methods Abstract Methods Deprecated Methods Modifier and Type Method Description static InstanceStreamServicegetInstance(Session session)Deprecated.The method provides the default implementation of the instance stream service.voidrecreateStreams(Identifier instanceName)Deprecated.The method recreates task reactor instance streams to extend their staleness time.voidrecreateStreamsIfRequired(Identifier instanceName)Deprecated.The method recreate task reactor instance streams to extend their staleness time only when the appropriate time passed since the last recreation.
-
-
-
Method Detail
-
recreateStreams
void recreateStreams(Identifier instanceName)
Deprecated.The method recreates task reactor instance streams to extend their staleness time.- Parameters:
instanceName- tha name of the Task Reactor instance.
-
recreateStreamsIfRequired
void recreateStreamsIfRequired(Identifier instanceName)
Deprecated.The method recreate task reactor instance streams to extend their staleness time only when the appropriate time passed since the last recreation.- Parameters:
instanceName- the name of the Task Reactor instance.
-
getInstance
static InstanceStreamService getInstance(Session session)
Deprecated.The method provides the default implementation of the instance stream service.- Parameters:
session- Snowpark session.- Returns:
- default instance stream service instance.
-
-