io.delta.standalone.actions

Class AddCDCFile

Object

io.delta.standalone.actions.AddCDCFile

All Implemented Interfaces:

Action, FileAction

public final class AddCDCFile
extends Object
implements FileAction

A change file containing CDC data for the Delta version it's within. Non-CDC readers should ignore this, CDC readers should scan all ChangeFiles in a version rather than computing changes from AddFile and RemoveFile actions.

Constructor Summary

Constructors

Constructor and Description
AddCDCFile(String path, java.util.Map<String,String> partitionValues, long size, java.util.Map<String,String> tags)

Method Summary

Modifier and Type	Method and Description
java.util.Map<String,String>	getPartitionValues()
String	getPath()
long	getSize()
java.util.Map<String,String>	getTags()
boolean	isDataChange()

Methods inherited from class Object

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

Constructor Detail

AddCDCFile

public AddCDCFile(@Nonnull
                  String path,
                  @Nonnull
                  java.util.Map<String,String> partitionValues,
                  long size,
                  @Nullable
                  java.util.Map<String,String> tags)

Method Detail

getPath

@Nonnull
public String getPath()

Specified by:

getPath in interface FileAction

Returns:

the relative path or the absolute path that should be added to the table. If it's a relative path, it's relative to the root of the table. Note: the path is encoded and should be decoded by new java.net.URI(path) when using it.

getPartitionValues

@Nonnull
public java.util.Map<String,String> getPartitionValues()

Returns:

an unmodifiable Map from partition column to value for this file. Partition values are stored as strings, using the following formats. An empty string for any type translates to a null partition value.

See Also:

Delta Protocol Partition Value Serialization

getSize

public long getSize()

Returns:

the size of this file in bytes

getTags

@Nullable
public java.util.Map<String,String> getTags()

Returns:

an unmodifiable Map containing metadata about this file

isDataChange

public boolean isDataChange()

Specified by:

isDataChange in interface FileAction

Returns:

whether any data was changed as a result of this file being added or removed.