Functions
|
Returns the array series |
|
Create a new integer column counting unique occurrences of values in |
|
Applies colmn transformations as defined by |
Classes
|
Subclass of |
|
Defines a single column and type-cast. |
|
Subclass of |
|
Defines the schema specifying the columns to be included in the output |
|
Subclass of |
|
Subclass of |
|
Subclass of |
|
Subclass of |
|
Subclass of |
- column_listjoin(df, col_name)[source]
Returns the array series
df[col_name]
as flattened string series.
- create_increment_col(df, column_name, groupby_column='username', timestamp_column='timestamp')[source]
Create a new integer column counting unique occurrences of values in
column_name
grouped per-day using the timestamp values intimestamp_column
and then grouping bygroupby_column
returning incrementing values starting at1
.
- process_dataframe(df_in, input_schema)[source]
Applies colmn transformations as defined by
input_schema