Package dev.frostlake.metastore.model

Class Pipe

java.lang.Object

dev.frostlake.metastore.SqlObject

dev.frostlake.metastore.model.Pipe

All Implemented Interfaces:

Taggable

public class Pipe
extends SqlObject

Represents a Snowflake PIPE for continuous data loading

Field Summary

Fields inherited from class dev.frostlake.metastore.SqlObject

comment, createdTime, name, owner

Constructor Summary

Constructors

Constructor	Description
Pipe(String name, String copyStatement, boolean autoIngest)
Pipe(String name, String copyStatement, boolean autoIngest, String notificationChannel)

Method Summary

Modifier and Type	Method	Description
String	getAwsSnsTopicArn()
String	getCopyStatement()
String	getErrorIntegration()
String	getIntegration()
int	getLastLoadedFileCount()
String	getLastLoadedTime()
String	getNotificationChannel()
String	getObjectType()	Get the type of this SQL object (e.g., "TABLE", "VIEW", "DATABASE") Subclasses should override to provide their specific type
String	getStatus()
String	getStatusJson()	The JSON returned by SYSTEM$PIPE_STATUS — reflects the pipe's actual execution state (RUNNING vs PAUSED) and notification channel, matching Snowflake's shape.
boolean	isAutoIngest()
boolean	isPaused()
void	setAwsSnsTopicArn(String awsSnsTopicArn)
void	setErrorIntegration(String errorIntegration)
void	setIntegration(String integration)
void	setLastLoadedFileCount(int lastLoadedFileCount)
void	setLastLoadedTime(String lastLoadedTime)
void	setPaused(boolean paused)
String	toString()

Methods inherited from class dev.frostlake.metastore.SqlObject

equals, getComment, getCreatedTime, getName, getOwner, getTagValue, getTagValues, hashCode, rename, setComment, setName, setOwner, setTag, unsetTag, withoutTrailingSemicolon

Methods inherited from class java.lang.Object

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

Constructor Details

Pipe

public Pipe(String name,
 String copyStatement,
 boolean autoIngest)

Pipe

public Pipe(String name,
 String copyStatement,
 boolean autoIngest,
 String notificationChannel)

Method Details

getCopyStatement

public String getCopyStatement()

isAutoIngest

public boolean isAutoIngest()

getNotificationChannel

public String getNotificationChannel()

isPaused

public boolean isPaused()

setPaused

public void setPaused(boolean paused)

getErrorIntegration

public String getErrorIntegration()

setErrorIntegration

public void setErrorIntegration(String errorIntegration)

getAwsSnsTopicArn

public String getAwsSnsTopicArn()

setAwsSnsTopicArn

public void setAwsSnsTopicArn(String awsSnsTopicArn)

getIntegration

public String getIntegration()

setIntegration

public void setIntegration(String integration)

getLastLoadedFileCount

public int getLastLoadedFileCount()

setLastLoadedFileCount

public void setLastLoadedFileCount(int lastLoadedFileCount)

getLastLoadedTime

public String getLastLoadedTime()

setLastLoadedTime

public void setLastLoadedTime(String lastLoadedTime)

getStatus

public String getStatus()

getStatusJson

public String getStatusJson()

The JSON returned by SYSTEM$PIPE_STATUS — reflects the pipe's actual execution state (RUNNING vs PAUSED) and notification channel, matching Snowflake's shape.

getObjectType

public String getObjectType()

Description copied from class: SqlObject

Get the type of this SQL object (e.g., "TABLE", "VIEW", "DATABASE") Subclasses should override to provide their specific type

Specified by:

getObjectType in class SqlObject

Returns:

The object type as a string

toString

public String toString()

Overrides:

toString in class SqlObject