State (Spark 4.1.0-preview3 JavaDoc)

org.apache.spark.sql.pipelines.graph.State

public class State extends Object

Constructor Summary

Constructors

Constructor

Description

State()
Method Summary

Modifier and Type

Method

Description

static org.apache.spark.internal.Logging.LogStringContext

LogStringContext(scala.StringContext sc)

static org.slf4j.Logger

org$apache$spark$internal$Logging$$log_()

static void

org$apache$spark$internal$Logging$$log__$eq(org.slf4j.Logger x$1)

static scala.collection.immutable.Seq<Input>

reset(DataflowGraph resolvedGraph, PipelineUpdateContext env)

Performs the following on targets selected for full refresh: - Clearing checkpoint data - Truncating table data

Methods inherited from class java.lang.Object
equals, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Details
- State
  
  public State()
Method Details
- reset
  
  public static scala.collection.immutable.Seq<Input> reset(DataflowGraph resolvedGraph, PipelineUpdateContext env)
  
  Performs the following on targets selected for full refresh: - Clearing checkpoint data - Truncating table data
  
  Parameters:
  
  resolvedGraph - (undocumented)
  
  env - (undocumented)
  
  Returns:
  
  (undocumented)
- org$apache$spark$internal$Logging$$log_
  
  public static org.slf4j.Logger org$apache$spark$internal$Logging$$log_()
- org$apache$spark$internal$Logging$$log__$eq
  
  public static void org$apache$spark$internal$Logging$$log__$eq(org.slf4j.Logger x$1)
- LogStringContext
  
  public static org.apache.spark.internal.Logging.LogStringContext LogStringContext(scala.StringContext sc)