Code
Hub
Workspaces
Following
Trending
Connect
MCP
copy
Create free account
hub
/
github.com/data-integrations/wrangler
/ functions
Functions
3,047 in github.com/data-integrations/wrangler
⨍
Functions
3,047
◇
Types & classes
631
↓ 686 callers
Method
get
Given the name of the directive, returns the information related to the directive. @param namespace the namespace of the directive @param name of the
wrangler-core/src/main/java/io/cdap/wrangler/registry/DirectiveRegistry.java:51
↓ 681 callers
Method
add
d Sets a variable with the value. @param name of the variable. @param value of the variable. @return 'this' context.
wrangler-core/src/main/java/io/cdap/wrangler/expression/ELContext.java:153
↓ 673 callers
Method
of
Method provides an easy way to translate ellipses parameters into a array of columns. @param columns list source or target columns of type {@link Str
wrangler-api/src/main/java/io/cdap/wrangler/api/lineage/Many.java:69
↓ 501 callers
Method
getValue
Gets a single value from the {@link JsonElement}. The value could be {@link JsonObject} or {@link JsonArray} or {@link JsonPrimitive}. @param element
wrangler-core/src/main/java/io/cdap/directives/parser/JsParser.java:198
↓ 470 callers
Method
format
Formats the string in way similar to String format. @param str format of string. @param args arguments to included in the string. @return A formatted
wrangler-core/src/main/java/io/cdap/functions/Global.java:154
↓ 420 callers
Method
size
Returns the number of tokens that are mapped to arguments. <p>The optional arguments specified during the <code>UsageDefinition</code> are not includ
wrangler-api/src/main/java/io/cdap/wrangler/api/Arguments.java:58
↓ 417 callers
Method
value
Returns the {@code value} of the object wrapped by the implementation of this interface. @return {@code value} wrapped by the implementation of this
wrangler-api/src/main/java/io/cdap/wrangler/api/parser/Token.java:42
↓ 392 callers
Method
build
Instantiates a new Conformer.
wrangler-core/src/main/java/io/cdap/directives/validation/conformers/Conformer.java:65
↓ 267 callers
Method
execute
Executes the directives on the record specified. @param recipe to be executed. @param rows to be executed on directives. @return transformed directiv
wrangler-core/src/test/java/io/cdap/wrangler/TestingRig.java:79
↓ 235 callers
Method
getName
<code>string name = 1;</code>
wrangler-core/src/test/java/com/example/tutorial/AddressBookProtos.java:24
↓ 231 callers
Method
add
Adds a value into row with name. @param name of the value to be added to row. @param value to be added to row.
wrangler-api/src/main/java/io/cdap/wrangler/api/Row.java:138
↓ 220 callers
Method
get
A value associated with the variable in the transient store. @param name of the variable to be retrieved. @param <T> type of the value to be returned
wrangler-api/src/main/java/io/cdap/wrangler/api/TransientStore.java:40
↓ 207 callers
Method
define
This method provides a way for the developer to provide information about the arguments expected by this directive. The definition of arguments would
wrangler-api/src/main/java/io/cdap/wrangler/api/Directive.java:117
↓ 181 callers
Method
add
Adds a new entry to the schema. @param id the id of the schema to add @param specification the schema to be added @throws SchemaNotFoundException if
wrangler-storage/src/main/java/io/cdap/wrangler/dataset/schema/SchemaRegistry.java:193
↓ 178 callers
Method
convert
Applies the distance conversion. @param value to be converted from 'from' distance to 'to' distance. @return converted value.
wrangler-core/src/main/java/io/cdap/wrangler/dq/ConvertDistances.java:120
↓ 162 callers
Method
getNextToken
(StringTokenizer tokenizer, String directive, String field, int lineno)
wrangler-core/src/main/java/io/cdap/wrangler/parser/MigrateToV2.java:805
↓ 140 callers
Method
getType
<code>.tutorial.Person.PhoneType type = 2;</code>
wrangler-core/src/test/java/com/example/tutorial/AddressBookProtos.java:301
↓ 124 callers
Method
valueOf
@deprecated Use {@link #forNumber(int)} instead.
wrangler-core/src/test/java/com/example/tutorial/AddressBookProtos.java:218
↓ 114 callers
Method
getMessage
@return Readable form of status of processing in the backend.
wrangler-core/src/main/java/io/cdap/wrangler/clients/Response.java:53
↓ 98 callers
Method
isEmpty
Checks if a value is a empty or not. @param value representing a empty. @return true if empty, else false.
wrangler-core/src/main/java/io/cdap/functions/Types.java:72
↓ 96 callers
Method
respond
(Namespace namespace)
wrangler-service/src/main/java/io/cdap/wrangler/service/common/AbstractWranglerHandler.java:288
↓ 94 callers
Method
builder
This is a static method for creating a builder for the <code>UsageDefinition</code> object. In order to create a <code>UsageDefinition</code>, a build
wrangler-api/src/main/java/io/cdap/wrangler/api/parser/UsageDefinition.java:156
↓ 92 callers
Method
find
Finds a column index based on the name of the column. The col name is case insensitive. @param col to be searched within the row. @return -1 if not p
wrangler-api/src/main/java/io/cdap/wrangler/api/Row.java:161
↓ 87 callers
Method
add
Add a character to the word being stemmed. When you are finished adding characters, you can call stem(void) to stem the word.
wrangler-core/src/main/java/io/cdap/directives/nlp/internal/PorterStemmer.java:83
↓ 86 callers
Method
getValue
Gets a value of row at specified index. @param idx from where the value should be retrieved. @return value at index (idx).
wrangler-api/src/main/java/io/cdap/wrangler/api/Row.java:101
↓ 85 callers
Method
col
(String value)
wrangler-core/src/main/java/io/cdap/wrangler/parser/MigrateToV2.java:789
↓ 81 callers
Method
getFields
@return List of fields of record.
wrangler-api/src/main/java/io/cdap/wrangler/api/Row.java:201
↓ 79 callers
Method
readable
@return a readable {@link String} version of the transformation to be included in lineage.
wrangler-api/src/main/java/io/cdap/wrangler/api/lineage/Mutation.java:60
↓ 78 callers
Method
builder
@return a instance of {@link Mutation.Builder}
wrangler-api/src/main/java/io/cdap/wrangler/api/lineage/Mutation.java:74
↓ 75 callers
Method
run
(WorkspaceDataset ws)
wrangler-storage/src/test/java/io/cdap/wrangler/dataset/WorkspaceDatasetTest.java:293
↓ 66 callers
Method
contains
This method checks if there exists a token named <code>name</code> registered with this object. The <code>name</code> is expected to the same as spec
wrangler-api/src/main/java/io/cdap/wrangler/api/Arguments.java:76
↓ 63 callers
Method
set
Sets the value of the object for variable named 'name'. @param name of the variable for which the value needs to be set. @param value of the variable
wrangler-api/src/main/java/io/cdap/wrangler/api/TransientStore.java:48
↓ 62 callers
Method
getProperties
@return Properties associated with the request.
wrangler-proto/src/main/java/io/cdap/wrangler/proto/Request.java:48
↓ 62 callers
Method
name
@return a <code>String</code> type specifying the name of the directive.
wrangler-core/src/main/java/io/cdap/wrangler/registry/DirectiveInfo.java:119
↓ 61 callers
Method
toString
()
wrangler-api/src/main/java/io/cdap/wrangler/api/LazyNumber.java:91
↓ 60 callers
Method
parse
Generates a configured set of {@link Executor} to be executed. @return List of {@link Executor}.
wrangler-api/src/main/java/io/cdap/wrangler/api/RecipeParser.java:33
↓ 59 callers
Method
relation
A standard relation between source of {@link ColumnName} to target of {@link ColumnName}. @param source a instance of {@link ColumnName} source. @par
wrangler-api/src/main/java/io/cdap/wrangler/api/lineage/Mutation.java:188
↓ 56 callers
Method
ends
(String s)
wrangler-core/src/main/java/io/cdap/directives/nlp/internal/PorterStemmer.java:244
↓ 51 callers
Method
intValue
Returns the value of the specified number as an <code>int</code>. This may involve rounding or truncation. @return the numeric value represented by
wrangler-api/src/main/java/io/cdap/wrangler/api/LazyNumber.java:38
↓ 50 callers
Method
width
@return width of the row.
wrangler-api/src/main/java/io/cdap/wrangler/api/Row.java:194
↓ 45 callers
Method
select
Selects the sub-record based on the path specified. @param schema to be used as source to apply the path to. @param path to be applied on the {@link
wrangler-core/src/main/java/io/cdap/functions/DDL.java:217
↓ 43 callers
Method
getNamespace
@return namespace that the program is being executed in
wrangler-api/src/main/java/io/cdap/wrangler/api/ExecutorContext.java:50
↓ 43 callers
Method
length
@return width of the row.
wrangler-api/src/main/java/io/cdap/wrangler/api/Row.java:186
↓ 42 callers
Method
getField
()
wrangler-transform/src/main/java/io/cdap/wrangler/Wrangler.java:790
↓ 42 callers
Method
getKey
(NamespacedId id)
wrangler-storage/src/main/java/io/cdap/wrangler/dataset/workspace/WorkspaceDataset.java:371
↓ 41 callers
Method
append
(FullHttpRequest request, HttpResponder responder, @HeaderParam("C") String headerC)
wrangler-core/src/test/java/io/cdap/directives/external/InvokeHttpTest.java:77
↓ 40 callers
Method
doubleValue
Returns the value of the specified number as a <code>double</code>. This may involve rounding. @return the numeric value represented by this object
wrangler-api/src/main/java/io/cdap/wrangler/api/LazyNumber.java:86
↓ 40 callers
Method
toString
()
wrangler-core/src/main/java/io/cdap/wrangler/utils/Manifest.java:80
↓ 39 callers
Method
execute
Executes the pipeline on the input. @param input List of Input record of type I. @param schema Schema to which the output should be mapped. @return P
wrangler-api/src/main/java/io/cdap/wrangler/api/RecipePipeline.java:42
↓ 39 callers
Method
getId
<pre> Unique ID number for this person. </pre> <code>int32 id = 2;</code>
wrangler-core/src/test/java/com/example/tutorial/AddressBookProtos.java:38
↓ 37 callers
Method
close
Destroys the pipeline.
wrangler-api/src/main/java/io/cdap/wrangler/api/RecipePipeline.java:62
↓ 37 callers
Method
toString
After a word has been stemmed, it can be retrieved by toString(), or a reference to the internal buffer can be retrieved by getResultBuffer and getRes
wrangler-core/src/main/java/io/cdap/directives/nlp/internal/PorterStemmer.java:119
↓ 35 callers
Method
getColumn
Gets a column name by index. @param idx to retrieve the name of the column. @return name of the column.
wrangler-api/src/main/java/io/cdap/wrangler/api/Row.java:81
↓ 35 callers
Method
getSchema
Generates the CDAP Schema for the given object @param value the value to retrieve schema @param name name of the field @return the schema of this obj
wrangler-core/src/main/java/io/cdap/wrangler/utils/SchemaConverter.java:90
↓ 35 callers
Method
getWorkspace
@return Workspace specification associated with the request.
wrangler-proto/src/main/java/io/cdap/wrangler/proto/Request.java:33
↓ 35 callers
Method
quote
(String value)
wrangler-core/src/main/java/io/cdap/wrangler/parser/MigrateToV2.java:777
↓ 35 callers
Method
toByteArray
Converts an object of type T into bytes. @param object to be serialized into bytes. @return byte array of serialized object.
wrangler-core/src/main/java/io/cdap/wrangler/utils/ObjectSerDe.java:42
↓ 35 callers
Method
toJson
The class implementing this interface will return the {@code JsonElement} instance including the values of the object. @return {@code JsonElement} ob
wrangler-api/src/main/java/io/cdap/wrangler/api/parser/Token.java:58
↓ 34 callers
Method
getSchema
()
wrangler-core/src/test/java/io/cdap/directives/parser/ParseAvroTest.java:130
↓ 34 callers
Method
longValue
Returns the value of the specified number as a <code>long</code>. This may involve rounding or truncation. @return the numeric value represented by
wrangler-api/src/main/java/io/cdap/wrangler/api/LazyNumber.java:58
↓ 34 callers
Method
trim
Remove trailing and leading characters which may be empty string, space string,\t,\n,\r,\f...any space, break related characters. @param input - the
wrangler-core/src/main/java/io/cdap/directives/transformation/Trimmer.java:65
↓ 32 callers
Method
get
(StructuredTableContext context)
wrangler-storage/src/main/java/io/cdap/wrangler/dataset/workspace/WorkspaceDataset.java:106
↓ 32 callers
Method
toBytes
Converts a String value to byte array. @param value of type string to be converted to byte array. @return byte array value of the string passed.
wrangler-core/src/main/java/io/cdap/functions/Global.java:77
↓ 31 callers
Method
columns
@return a instance of <pre>List<String></pre> that returns columns associated with source or target.
wrangler-api/src/main/java/io/cdap/wrangler/api/lineage/Many.java:59
↓ 30 callers
Method
next
()
wrangler-core/src/main/java/io/cdap/wrangler/sampling/Poisson.java:105
↓ 29 callers
Method
getObject
()
wrangler-core/src/main/java/io/cdap/wrangler/expression/ELResult.java:29
↓ 29 callers
Method
multiply
Arithmetic operation - multiply any number of columns, of any types. Output type is most general of input types. Returns null if any input value is nu
wrangler-core/src/main/java/io/cdap/wrangler/utils/ArithmeticOperations.java:166
↓ 28 callers
Method
builder
(NamespacedId id, String name)
wrangler-storage/src/main/java/io/cdap/wrangler/dataset/workspace/Workspace.java:95
↓ 28 callers
Method
call
(SchemaRegistryCallable<T> callable)
wrangler-storage/src/test/java/io/cdap/wrangler/dataset/SchemaRegistryTest.java:213
↓ 28 callers
Method
call
(WorkspaceCallable<T> callable)
wrangler-storage/src/test/java/io/cdap/wrangler/dataset/WorkspaceDatasetTest.java:278
↓ 28 callers
Method
getTable
()
wrangler-service/src/main/java/io/cdap/wrangler/service/spanner/SpannerSpecification.java:66
↓ 28 callers
Method
name
@return Name of this <code>TokenDefinition</code>
wrangler-api/src/main/java/io/cdap/wrangler/api/parser/TokenDefinition.java:83
↓ 28 callers
Method
r
(String s)
wrangler-core/src/main/java/io/cdap/directives/nlp/internal/PorterStemmer.java:271
↓ 27 callers
Method
setValue
(String name, String value)
wrangler-core/src/main/java/io/cdap/directives/parser/ParseLog.java:131
↓ 26 callers
Method
add
Arithmetic operation - Find the sum of any number of columns, of any valid types. Output type is most general of input types. Returns null if any inpu
wrangler-core/src/main/java/io/cdap/wrangler/utils/ArithmeticOperations.java:88
↓ 26 callers
Method
builder
Static method for creating an instance of the {@code RecipeSymbol.Builder}. @return a instance of builder.
wrangler-api/src/main/java/io/cdap/wrangler/api/RecipeSymbol.java:121
↓ 26 callers
Method
equals
(Object o)
wrangler-core/src/main/java/io/cdap/wrangler/utils/Manifest.java:61
↓ 26 callers
Method
getFirst
@return First element of the pair.
wrangler-api/src/main/java/io/cdap/wrangler/api/Pair.java:39
↓ 26 callers
Method
getId
()
wrangler-proto/src/main/java/io/cdap/wrangler/proto/NamespacedId.java:43
↓ 26 callers
Method
getMethod
@return String representation of enum.
wrangler-service/src/main/java/io/cdap/wrangler/SamplingMethod.java:41
↓ 26 callers
Method
removeTrailingAndLeading
Remove trailing and leading characters and the remove Character is whitespace only. <br/> <br/> Note: this is not equals input.trim() for example: <br
wrangler-core/src/main/java/io/cdap/wrangler/dq/ConvertString.java:117
↓ 26 callers
Method
run
(ConnectionStoreCallable<T> callable)
wrangler-storage/src/test/java/io/cdap/wrangler/dataset/ConnectionStoreTest.java:254
↓ 26 callers
Method
setType
(DataType type)
wrangler-storage/src/main/java/io/cdap/wrangler/dataset/workspace/WorkspaceMeta.java:104
↓ 25 callers
Method
builder
(Recipe recipe)
wrangler-storage/src/main/java/io/cdap/wrangler/dataset/recipe/RecipeRow.java:56
↓ 25 callers
Method
floatValue
Returns the value of the specified number as a <code>float</code>. This may involve rounding. @return the numeric value represented by this object a
wrangler-api/src/main/java/io/cdap/wrangler/api/LazyNumber.java:74
↓ 25 callers
Method
getSecond
@return Second element of the pair.
wrangler-api/src/main/java/io/cdap/wrangler/api/Pair.java:46
↓ 25 callers
Method
isEmpty
Detect if the given value is blank or null. @param value the value to be detected. @return true if the value is blank or null, false otherwise.
wrangler-core/src/main/java/io/cdap/wrangler/dq/TypeInference.java:154
↓ 25 callers
Method
next
Returns the next line in the wrapped <code>Reader. @return the next line from the input @throws NoSuchElementException if there is no line to return
wrangler-service/src/main/java/io/cdap/wrangler/service/explorer/BoundedLineInputStream.java:122
↓ 25 callers
Method
toArray
()
wrangler-test/src/main/java/io/cdap/wrangler/test/api/TestRecipe.java:40
↓ 24 callers
Method
errors
Returns records that are errored out. @return records that have errored out.
wrangler-api/src/main/java/io/cdap/wrangler/api/RecipePipeline.java:57
↓ 24 callers
Method
getGeneration
()
wrangler-proto/src/main/java/io/cdap/wrangler/proto/Namespace.java:47
↓ 24 callers
Method
setUpdatedTimeMillis
(long updatedTimeMillis)
wrangler-proto/src/main/java/io/cdap/wrangler/proto/recipe/v2/Recipe.java:146
↓ 24 callers
Method
warn
(Object o)
wrangler-core/src/main/java/io/cdap/wrangler/expression/EL.java:274
↓ 23 callers
Method
addOrSet
Adds or sets the value. @param name of the field to be either set or added to record. @param value to be added.
wrangler-api/src/main/java/io/cdap/wrangler/api/Row.java:217
↓ 23 callers
Method
all
A relation that has association with all in the output field. This method is used usually during parse scenarios. @param sources list of sources to b
wrangler-api/src/main/java/io/cdap/wrangler/api/lineage/Mutation.java:160
↓ 23 callers
Method
setCreatedTimeMillis
(long createdTimeMillis)
wrangler-proto/src/main/java/io/cdap/wrangler/proto/recipe/v2/Recipe.java:141
↓ 23 callers
Method
type
Returns the {@code TokenType} of the object represented by the implementation of this interface. @return {@code TokenType} of the implementation obje
wrangler-api/src/main/java/io/cdap/wrangler/api/parser/Token.java:50
↓ 22 callers
Method
add
Flattens the {@link GenericRecord}. @param genericRecord to be flattened. @param row to be flattened into @param name of the field to be flattened.
wrangler-core/src/main/java/io/cdap/directives/parser/ParseAvroFile.java:130
↓ 22 callers
Method
builder
(NamespaceSummary namespace)
wrangler-proto/src/main/java/io/cdap/wrangler/proto/recipe/v2/RecipeId.java:64
↓ 22 callers
Method
create
Creates an entry in the {@link ConnectionStore} for object {@link Connection}. This method creates the id and returns if after successfully updating
wrangler-storage/src/main/java/io/cdap/wrangler/dataset/connections/ConnectionStore.java:115
next →
1–100 of 3,047, ranked by callers