MCPcopy Create free account

hub / github.com/data-integrations/wrangler / functions

Functions1,973 in github.com/data-integrations/wrangler

↓ 267 callersMethodget
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/co/cask/wrangler/api/TransientStore.java:40
↓ 238 callersMethodsize
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/co/cask/wrangler/api/Arguments.java:58
↓ 167 callersMethodgetValue
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/co/cask/directives/parser/JsParser.java:189
↓ 162 callersMethodformat
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/co/cask/functions/Global.java:151
↓ 156 callersMethodexecute
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/co/cask/wrangler/TestingRig.java:61
↓ 137 callersMethodgetMessage
@return Readable form of status of processing in the backend.
wrangler-core/src/main/java/co/cask/wrangler/clients/Response.java:53
↓ 117 callersMethodadd
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/co/cask/wrangler/expression/ELContext.java:117
↓ 100 callersMethodbuild
()
wrangler-core/src/test/java/com/example/tutorial/AddressBookProtos.java:1228
↓ 91 callersMethodvalue
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/co/cask/wrangler/api/parser/Token.java:42
↓ 82 callersMethoddefine
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/co/cask/wrangler/api/Directive.java:117
↓ 81 callersMethodbuilder
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/co/cask/wrangler/api/parser/UsageDefinition.java:175
↓ 76 callersMethodgetName
<code>string name = 1;</code>
wrangler-core/src/test/java/com/example/tutorial/AddressBookProtos.java:24
↓ 71 callersMethodadd
Adds a new version of schema to an existing schema entry. @param id of the schema. @param specification of the schema to be added. @throws SchemaRegi
wrangler-service/src/main/java/co/cask/wrangler/dataset/schema/SchemaRegistry.java:108
↓ 70 callersMethodfind
Finds a column index based on the name of the column. @param col to be searched within the row. @return null if not present, else the index at which
wrangler-api/src/main/java/co/cask/wrangler/api/Row.java:161
↓ 67 callersMethodtoString
@return string representation of object.
wrangler-service/src/main/java/co/cask/wrangler/dataset/connections/Connection.java:185
↓ 66 callersMethodgetType
<code>.tutorial.Person.PhoneType type = 2;</code>
wrangler-core/src/test/java/com/example/tutorial/AddressBookProtos.java:301
↓ 65 callersMethoderror
Sends the error response back to client. @param responder to respond to the service request. @param message to be included as part of the error
wrangler-service/src/main/java/co/cask/wrangler/ServiceUtils.java:62
↓ 63 callersMethodlength
@return Length of the row.
wrangler-api/src/main/java/co/cask/wrangler/api/Row.java:175
↓ 62 callersMethodsendJson
Returns a Json response back to client. @param responder to respond to the service request. @param status code to be returned to client. @param body
wrangler-service/src/main/java/co/cask/wrangler/ServiceUtils.java:102
↓ 51 callersMethodisEmpty
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/co/cask/functions/Types.java:72
↓ 51 callersMethodtoString
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/co/cask/directives/nlp/internal/PorterStemmer.java:113
↓ 44 callersMethodadd
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/co/cask/wrangler/api/Row.java:138
↓ 43 callersMethodcontains
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/co/cask/wrangler/api/Arguments.java:76
↓ 36 callersMethodfromJson
Converts from JSON string to object of type T. @param json string to be converted to object. @return instance of type T object.
wrangler-service/src/main/java/co/cask/wrangler/dataset/AbstractTableStore.java:107
↓ 33 callersMethodadd
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/co/cask/directives/nlp/internal/PorterStemmer.java:83
↓ 32 callersMethodexecute
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/co/cask/wrangler/api/RecipePipeline.java:45
↓ 31 callersMethodtrim
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/co/cask/directives/transformation/Trimmer.java:65
↓ 30 callersMethodtoJson
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/co/cask/wrangler/api/parser/Token.java:58
↓ 29 callersMethodname
()
wrangler-api/src/main/java/co/cask/wrangler/api/DirectiveInfo.java:88
↓ 28 callersMethodparse
Generates a configured set of {@link Executor} to be executed. @return List of {@link Executor}.
wrangler-api/src/main/java/co/cask/wrangler/api/RecipeParser.java:35
↓ 27 callersMethodtoBytes
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/co/cask/functions/Global.java:74
↓ 25 callersMethodtoString
Converts a java type to String. @param object of any type. @return object converted to type string.
wrangler-core/src/main/java/co/cask/wrangler/utils/TypeConvertor.java:32
↓ 24 callersMethodequals
(final java.lang.Object obj)
wrangler-core/src/test/java/com/example/tutorial/AddressBookProtos.java:1042
↓ 23 callersMethodgetFields
@return List of fields of record.
wrangler-api/src/main/java/co/cask/wrangler/api/Row.java:182
↓ 22 callersMethodnext
()
wrangler-core/src/main/java/co/cask/wrangler/sampling/Poisson.java:103
↓ 22 callersMethodtoByteArray
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/co/cask/wrangler/utils/ObjectSerDe.java:41
↓ 21 callersMethodcreate
Creates a recipe entry in the recipe store. Following is the response { "status" : 200, "message" : "Successfully created recipe with id 'test'"
wrangler-service/src/main/java/co/cask/wrangler/service/recipe/RecipeService.java:105
↓ 20 callersMethodconvert
Applies the distance conversion. @param value to be converted from 'from' distance to 'to' distance. @return converted value.
wrangler-core/src/main/java/co/cask/wrangler/dq/ConvertDistances.java:120
↓ 20 callersMethodgetContent
@return Content as received by the HTTP multipart/form body.
wrangler-service/src/main/java/co/cask/wrangler/RequestExtractor.java:67
↓ 20 callersMethodgetValue
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/co/cask/wrangler/api/Row.java:101
↓ 20 callersMethodsetValue
(final String name, final String value)
wrangler-core/src/main/java/co/cask/directives/parser/ParseLog.java:112
↓ 19 callersMethodisEmpty
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/co/cask/wrangler/dq/TypeInference.java:153
↓ 18 callersMethodclose
Closes the underlying <code>Reader quietly. This method is useful if you only want to process the first few lines of a larger file. If you do not clos
wrangler-service/src/main/java/co/cask/wrangler/service/explorer/BoundedLineInputStream.java:149
↓ 18 callersMethodgetInstance
Returns a instance of {@link SchemaRegistryClient} initialized with service url. @param context of the pipeline in which this client is invoked. @ret
wrangler-core/src/main/java/co/cask/wrangler/clients/SchemaRegistryClient.java:97
↓ 18 callersMethodhasNext
()
wrangler-core/src/main/java/co/cask/wrangler/sampling/Poisson.java:89
↓ 18 callersMethodnext
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/co/cask/wrangler/service/explorer/BoundedLineInputStream.java:122
↓ 17 callersMethodbuild
Returns a fully constructed and valid <code>RecipeSymbol</code> object. @return An instance of <code>RecipeSymbol</code>
wrangler-api/src/main/java/co/cask/wrangler/api/RecipeSymbol.java:227
↓ 17 callersMethoderrors
Returns records that are errored out. @return records that have errored out.
wrangler-api/src/main/java/co/cask/wrangler/api/RecipePipeline.java:60
↓ 17 callersMethodvalueOf
@deprecated Use {@link #forNumber(int)} instead.
wrangler-core/src/test/java/com/example/tutorial/AddressBookProtos.java:218
↓ 16 callersMethodsuccess
Sends the success response back to client. @param responder to respond to the service request. @param message to be included as part of the error
wrangler-service/src/main/java/co/cask/wrangler/ServiceUtils.java:113
↓ 15 callersMethodaddOrSet
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/co/cask/wrangler/api/Row.java:198
↓ 15 callersMethodbuilder
Static method for creating an instance of the {@code RecipeSymbol.Builder}. @return a instance of builder.
wrangler-api/src/main/java/co/cask/wrangler/api/RecipeSymbol.java:121
↓ 15 callersMethodcompile
Compiles the recipe that is supplied in a <code>String</code> format. @param recipe representing the <code>String</code> form of recipe. @return <cod
wrangler-api/src/main/java/co/cask/wrangler/api/Compiler.java:44
↓ 15 callersMethodgetColumn
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/co/cask/wrangler/api/Row.java:81
↓ 15 callersMethodgetSchema
()
wrangler-core/src/main/java/co/cask/wrangler/codec/AbstractAvroDecoder.java:41
↓ 15 callersMethodname
@return Name of this <code>TokenDefinition</code>
wrangler-api/src/main/java/co/cask/wrangler/api/parser/TokenDefinition.java:85
↓ 15 callersMethodtestRegex
(String regex, RegexInputOutput[] regexInputOutputs)
wrangler-core/src/test/java/co/cask/directives/transformation/ExtractRegexGroupsTest.java:299
↓ 15 callersMethodvalidate
(ZonedDateTime date, String method)
wrangler-core/src/main/java/co/cask/functions/Dates.java:293
↓ 14 callersMethodaddToken
This method provides a way to add a <code>Token</code> to the <code>TokenGroup</code>. @param token to be added to the token group.
wrangler-api/src/main/java/co/cask/wrangler/api/RecipeSymbol.java:197
↓ 14 callersMethodgetDefaultInstance
()
wrangler-core/src/test/java/com/example/tutorial/AddressBookProtos.java:1793
↓ 14 callersMethodintValue
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/co/cask/wrangler/api/LazyNumber.java:38
↓ 13 callersMethodclose
Closes any resources acquired during initialization or otherwise.
wrangler-core/src/main/java/co/cask/wrangler/registry/UserDirectiveRegistry.java:228
↓ 13 callersMethodgetFirst
@return First element of the pair.
wrangler-api/src/main/java/co/cask/wrangler/api/Pair.java:36
↓ 13 callersMethodinitialize
Initialises the directive with a {@link DirectiveContext}. @param context
wrangler-core/src/main/java/co/cask/wrangler/parser/GrammarBasedParser.java:138
↓ 13 callersMethodisValid
@param type the expected type @param value the value to be detected @return true if the type of value is expected, false otherwise.
wrangler-core/src/main/java/co/cask/wrangler/dq/TypeInference.java:163
↓ 13 callersMethodset
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/co/cask/wrangler/api/TransientStore.java:48
↓ 13 callersMethodtoIdKey
(String id)
wrangler-service/src/main/java/co/cask/wrangler/dataset/schema/SchemaRegistry.java:340
↓ 12 callersMethodgetSecond
@return Second element of the pair.
wrangler-api/src/main/java/co/cask/wrangler/api/Pair.java:43
↓ 12 callersMethoditerator
()
wrangler-core/src/main/java/co/cask/wrangler/parser/SyntaxErrorListener.java:88
↓ 12 callersMethodnewBuilder
()
wrangler-core/src/test/java/com/example/tutorial/AddressBookProtos.java:1146
↓ 11 callersMethodadd
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/co/cask/directives/parser/ParseAvroFile.java:119
↓ 11 callersMethodcreateWorkspaceMeta
Creates a workspace meta entry, with default type as {@link DataType#BINARY} and empty properties. @param id id of workspace. @param name of the work
wrangler-service/src/main/java/co/cask/wrangler/dataset/workspace/WorkspaceDataset.java:81
↓ 11 callersMethodexecute
(java.sql.Connection connection)
wrangler-service/src/main/java/co/cask/wrangler/service/database/DatabaseService.java:191
↓ 11 callersMethodgetAllProps
@return all the properties associated with the connection.
wrangler-service/src/main/java/co/cask/wrangler/dataset/connections/Connection.java:178
↓ 11 callersMethodhasNext
Indicates whether the <code>Reader has more lines. If there is an <code>IOException then {@link #close()} will be called on this instance. @return <c
wrangler-service/src/main/java/co/cask/wrangler/service/explorer/BoundedLineInputStream.java:78
↓ 11 callersMethoditerator
A static method to create instance of <code>BoundedLineInputStream</code>. This method creates the instance specifying the character encoding and numb
wrangler-service/src/main/java/co/cask/wrangler/service/explorer/BoundedLineInputStream.java:189
↓ 11 callersMethodmigrate
Migrates each directive from one version to other. @return directives transformed into a newer version.
wrangler-api/src/main/java/co/cask/wrangler/api/GrammarMigrator.java:28
↓ 11 callersMethodread
This methods provides an efficiently way to read a file from the file system specified by the <code>Location.</code>. It uses a bounded line stream th
wrangler-service/src/main/java/co/cask/wrangler/service/explorer/Explorer.java:124
↓ 11 callersMethodwriteProperties
(String id, Map<String, String> properties)
wrangler-service/src/main/java/co/cask/wrangler/dataset/workspace/WorkspaceDataset.java:321
↓ 10 callersMethodclear
()
wrangler-core/src/test/java/com/example/tutorial/AddressBookProtos.java:1202
↓ 10 callersMethodgenerateMD5
Generates a MD5 hash for a given string. This implementation is based on Bouncycastle. So, you would need to initialize the security provider to use
wrangler-service/src/main/java/co/cask/wrangler/ServiceUtils.java:47
↓ 10 callersMethodwrite
(String key, RecipeDatum datum)
wrangler-service/src/main/java/co/cask/wrangler/service/recipe/RecipeService.java:176
↓ 10 callersMethodwriteToWorkspace
(String id, byte[] key, DataType type, byte[] data)
wrangler-service/src/main/java/co/cask/wrangler/dataset/workspace/WorkspaceDataset.java:271
↓ 9 callersMethodcompile
(String[] recipe)
wrangler-core/src/test/java/co/cask/wrangler/TestingRig.java:134
↓ 9 callersMethodequals
(Object o)
wrangler-service/src/main/java/co/cask/wrangler/service/connections/ConnectionTypeConfig.java:69
↓ 9 callersMethodgetMethod
@return Method for sampling data.
wrangler-service/src/main/java/co/cask/wrangler/proto/Sampling.java:35
↓ 9 callersMethodgetProjectId
Get the project id for the connection
wrangler-service/src/main/java/co/cask/wrangler/service/gcp/GCPUtils.java:118
↓ 9 callersMethodgetProperties
@return Properties associated with the request.
wrangler-service/src/main/java/co/cask/wrangler/proto/Request.java:48
↓ 9 callersMethodgetSymbols
()
wrangler-api/src/main/java/co/cask/wrangler/api/CompileStatus.java:55
↓ 9 callersMethodgetType
@return type of the connection.
wrangler-service/src/main/java/co/cask/wrangler/dataset/connections/Connection.java:66
↓ 9 callersMethodinitialize
This method provides a way for the custom directive writer the ability to access the arguments passed by the users. <p>This method is invoked only on
wrangler-api/src/main/java/co/cask/wrangler/api/Executor.java:56
↓ 9 callersMethodremove
()
wrangler-core/src/main/java/co/cask/wrangler/sampling/Reservoir.java:110
↓ 9 callersMethodwarn
(Object o)
wrangler-core/src/main/java/co/cask/wrangler/expression/EL.java:230
↓ 8 callersMethodappend
(FullHttpRequest request, HttpResponder responder, @HeaderParam("C") String headerC)
wrangler-core/src/test/java/co/cask/directives/external/InvokeHttpTest.java:77
↓ 8 callersMethodcompile
(String recipe)
wrangler-core/src/main/java/co/cask/wrangler/parser/RecipeCompiler.java:40
↓ 8 callersMethoddoubleValue
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/co/cask/wrangler/api/LazyNumber.java:86
↓ 8 callersMethodfromString
Provided the connection type as string, determine the enum type of {@link ConnectionType}. @param from string for which the {@link ConnectionType} in
wrangler-service/src/main/java/co/cask/wrangler/service/connections/ConnectionType.java:56
↓ 8 callersMethodmergeFrom
(com.google.protobuf.Message other)
wrangler-core/src/test/java/com/example/tutorial/AddressBookProtos.java:1283
↓ 8 callersMethodtoKey
(String value)
wrangler-service/src/main/java/co/cask/wrangler/dataset/workspace/WorkspaceDataset.java:413
↓ 8 callersMethodvariables
()
wrangler-core/src/main/java/co/cask/wrangler/expression/EL.java:83
next →1–100 of 1,973, ranked by callers