MCPcopy Create free account

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

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

↓ 7 callersMethoddecode
(byte[] bytes)
wrangler-core/src/main/java/co/cask/wrangler/codec/Decoder.java:26
↓ 7 callersMethodgetBoolean
()
wrangler-core/src/main/java/co/cask/wrangler/expression/ELResult.java:33
↓ 7 callersMethodgetProp
Retrieves a property from the connection. @param key to be retrieved. @return the value for the key, else null.
wrangler-service/src/main/java/co/cask/wrangler/dataset/connections/Connection.java:107
↓ 7 callersMethodjoin
(JsonElement element, String separator)
wrangler-core/src/main/java/co/cask/functions/JSON.java:151
↓ 7 callersMethodlongValue
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/co/cask/wrangler/api/LazyNumber.java:58
↓ 7 callersMethodmigrate
Rewrites the directives in version 1.0 to version 2.0. @return directives converted to version 2.0.
wrangler-core/src/main/java/co/cask/wrangler/parser/MigrateToV2.java:67
↓ 7 callersMethodnotFound
Sends the error response back to client for not Found. @param responder to respond to the service request. @param message to be included as part of t
wrangler-service/src/main/java/co/cask/wrangler/ServiceUtils.java:75
↓ 7 callersMethodremoveRepeatedChar
Remove consecutive repeated characters by a specified char. @param input the source String @return the string with the source string removed if found
wrangler-core/src/main/java/co/cask/wrangler/dq/ConvertString.java:150
↓ 7 callersMethodset
Sets a variable with the value. @param name of the variable. @param value of the variable.
wrangler-core/src/main/java/co/cask/wrangler/expression/ELContext.java:105
↓ 6 callersMethodclose
()
wrangler-core/src/test/java/co/cask/wrangler/registry/CompositeDirectiveRegistryTest.java:115
↓ 6 callersMethodcompileFailure
(String[] recipe)
wrangler-core/src/test/java/co/cask/wrangler/TestingRig.java:145
↓ 6 callersMethoddetectFileType
Attempts to detect the type of the file through extensions and by reading the content of the file. @param location of the file who's content type nee
wrangler-service/src/main/java/co/cask/wrangler/service/FileTypeDetector.java:85
↓ 6 callersMethodgetDateTime
(ZonedDateTime zonedDateTime)
wrangler-core/src/main/java/co/cask/functions/Dates.java:287
↓ 6 callersMethodgetDescription
()
wrangler-core/src/main/java/co/cask/directives/lookup/StaticCatalog.java:52
↓ 6 callersMethodgetHeader
Extracts the HTTP header, if the header is not present, then default value is returned. @param name of the HTTP header to be extracted. @param defaul
wrangler-service/src/main/java/co/cask/wrangler/RequestExtractor.java:59
↓ 6 callersMethodgetId
<pre> Unique ID number for this person. </pre> <code>int32 id = 2;</code>
wrangler-core/src/test/java/com/example/tutorial/AddressBookProtos.java:38
↓ 6 callersMethodgetLocation
Trick, to extract the URI for a location. @param path to a Dataset. @return Location @throws URISyntaxException issue constructing the URI.
wrangler-service/src/main/java/co/cask/wrangler/service/explorer/Explorer.java:233
↓ 6 callersMethodgetNumber
<code>string number = 1;</code>
wrangler-core/src/test/java/com/example/tutorial/AddressBookProtos.java:287
↓ 6 callersMethodgetPort
()
wrangler-service/src/main/java/co/cask/wrangler/service/database/DatabaseService.java:185
↓ 6 callersMethodgetSchema
()
wrangler-service/src/main/java/co/cask/wrangler/service/common/Format.java:33
↓ 6 callersMethodgetService
Returns a valid service url. @param applicationId id of the application to which a service url. @param serviceId id of the service within application
wrangler-api/src/main/java/co/cask/wrangler/api/ExecutorContext.java:69
↓ 6 callersMethodgetVariables
Set of all the variables. @return list of all the variables.
wrangler-api/src/main/java/co/cask/wrangler/api/TransientStore.java:63
↓ 6 callersMethodparse
Generates a configured set of {@link Executor} to be executed. @return List of {@link Executor}.
wrangler-core/src/main/java/co/cask/wrangler/parser/GrammarBasedParser.java:76
↓ 6 callersMethodsetColumn
Sets the name of the column at a given index. @param idx at which the new name to be set. @param name of the column to be set at idx.
wrangler-api/src/main/java/co/cask/wrangler/api/Row.java:91
↓ 6 callersMethodsetValue
Updates the value of the row at index idx. @param idx index at which the value needs to be updated. @param value value to be updated at index (idx).
wrangler-api/src/main/java/co/cask/wrangler/api/Row.java:127
↓ 6 callersMethodtype
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/co/cask/wrangler/api/parser/Token.java:50
↓ 5 callersMethodIdentifier
Allocates a {@code String} object representing the {@code value} argument. @param value the value of the {@code String}.
wrangler-api/src/main/java/co/cask/wrangler/api/parser/Identifier.java:57
↓ 5 callersMethodends
(String s)
wrangler-core/src/main/java/co/cask/directives/nlp/internal/PorterStemmer.java:208
↓ 5 callersMethodensurePeopleIsMutable
()
wrangler-core/src/test/java/com/example/tutorial/AddressBookProtos.java:2279
↓ 5 callersMethodensurePhonesIsMutable
()
wrangler-core/src/test/java/com/example/tutorial/AddressBookProtos.java:1536
↓ 5 callersMethodgenerateKey
Generates a composite key that is a combination of namespace and object key. @param key specifies the key to be used to generate the composite key. @
wrangler-service/src/main/java/co/cask/wrangler/dataset/AbstractTableStore.java:162
↓ 5 callersMethodgetAliasName
Dereferences an alias if defined, else returns the directive itself. @param directive to be dereferenced. @return dereferenced directive or null.
wrangler-api/src/main/java/co/cask/wrangler/api/DirectiveConfig.java:75
↓ 5 callersMethodgetDirectives
@return List of directives that is part of recipe.
wrangler-service/src/main/java/co/cask/wrangler/service/recipe/RecipeDatum.java:117
↓ 5 callersMethodgetPeopleFieldBuilder
()
wrangler-core/src/test/java/com/example/tutorial/AddressBookProtos.java:2502
↓ 5 callersMethodgetPhonesFieldBuilder
()
wrangler-core/src/test/java/com/example/tutorial/AddressBookProtos.java:1759
↓ 5 callersMethodgetSpannerService
Create and return {@link Spanner} based on the credentials and project information provided in the connection
wrangler-service/src/main/java/co/cask/wrangler/service/gcp/GCPUtils.java:83
↓ 5 callersMethodgetTransientStore
@return A transient store.
wrangler-api/src/main/java/co/cask/wrangler/api/ExecutorContext.java:74
↓ 5 callersMethodinitialize
Initializes this validator. @throws Exception thrown when reserved words file is not accessible.
wrangler-core/src/main/java/co/cask/wrangler/validator/ColumnNameValidator.java:48
↓ 5 callersMethodisExcluded
Checks if the directive should be excluded. @param directive to checked if it has to be excluded. @return true if directive is excluded, false otherw
wrangler-api/src/main/java/co/cask/wrangler/api/DirectiveConfig.java:103
↓ 5 callersMethodisInteger
Detect if the given value is a integer type. @param value the value to be detected. @return true if the value is a integer type, false otherwise.
wrangler-core/src/main/java/co/cask/wrangler/dq/TypeInference.java:82
↓ 5 callersMethodisSuccess
()
wrangler-api/src/main/java/co/cask/wrangler/api/CompileStatus.java:44
↓ 5 callersMethodnow
@return current time in seconds.
wrangler-service/src/main/java/co/cask/wrangler/dataset/AbstractTableStore.java:185
↓ 5 callersMethodreadJson
(JsonReader reader, Schema schema)
wrangler-core/src/main/java/co/cask/wrangler/utils/StructuredRecordJsonConverter.java:142
↓ 5 callersMethodstop
()
wrangler-service/src/test/java/co/cask/wrangler/service/database/DatabaseServiceTest.java:252
↓ 5 callersMethodtoArray
()
wrangler-test/src/main/java/co/cask/wrangler/test/api/TestRecipe.java:40
↓ 5 callersMethodtoSchema
Generates a {@link Schema} given a row. @param id Schema id @return returns {@link Schema} @throws UnsupportedTypeException @throws JSONException
wrangler-core/src/main/java/co/cask/wrangler/utils/Json2Schema.java:69
↓ 5 callersMethodtoVersionColumn
(long version)
wrangler-service/src/main/java/co/cask/wrangler/dataset/schema/SchemaRegistry.java:344
↓ 5 callersMethodvalidate
Validates the T properties. @param name to be validated. @throws ValidatorException thrown when there are issues with validation.
wrangler-core/src/main/java/co/cask/wrangler/validator/ColumnNameValidator.java:68
↓ 5 callersMethodwriteJson
(JsonWriter writer, Schema schema, Object value)
wrangler-core/src/main/java/co/cask/wrangler/utils/StructuredRecordJsonConverter.java:281
↓ 4 callersMethodadd
(Row row)
wrangler-test/src/main/java/co/cask/wrangler/test/api/TestRows.java:34
↓ 4 callersMethodcons
(int i)
wrangler-core/src/main/java/co/cask/directives/nlp/internal/PorterStemmer.java:135
↓ 4 callersMethodconvertField
(Object field, Schema fieldSchema)
wrangler-core/src/main/java/co/cask/wrangler/utils/StructuredRecordConverter.java:98
↓ 4 callersMethoddebug
(Object o)
wrangler-core/src/main/java/co/cask/wrangler/expression/EL.java:150
↓ 4 callersMethoddecode
(String name, Object object, Schema schema)
wrangler-core/src/main/java/co/cask/wrangler/utils/RecordConvertor.java:110
↓ 4 callersMethoddestroy
()
wrangler-service/src/main/java/co/cask/wrangler/service/database/DriverCleanup.java:33
↓ 4 callersMethodexecuteWithErrors
Executes the directives on the record specified and returns the results as well as the errors. @param recipe to be executed. @param rows to be execut
wrangler-core/src/test/java/co/cask/wrangler/TestingRig.java:87
↓ 4 callersMethodfloatValue
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/co/cask/wrangler/api/LazyNumber.java:74
↓ 4 callersMethodfromString
Provided the sampling method as string, determine the enum type of {@link SamplingMethod}. @param from string for which the {@link SamplingMethod} in
wrangler-service/src/main/java/co/cask/wrangler/SamplingMethod.java:51
↓ 4 callersMethodgetBigQueryService
Create and return {@link BigQuery} based on the credentials and project information provided in the connection
wrangler-service/src/main/java/co/cask/wrangler/service/gcp/GCPUtils.java:74
↓ 4 callersMethodgetColumns
@return Set of columns tracked.
wrangler-core/src/main/java/co/cask/wrangler/statistics/ColumnMetric.java:71
↓ 4 callersMethodgetConnection
()
wrangler-service/src/test/java/co/cask/wrangler/service/database/DatabaseServiceTest.java:228
↓ 4 callersMethodgetData
(Connection connection, TableId tableId)
wrangler-service/src/main/java/co/cask/wrangler/service/bigquery/BigQueryService.java:344
↓ 4 callersMethodgetDatasetId
(String datasetStr, String connectionProject)
wrangler-service/src/main/java/co/cask/wrangler/service/bigquery/BigQueryService.java:538
↓ 4 callersMethodgetEmail
<code>string email = 3;</code>
wrangler-core/src/test/java/com/example/tutorial/AddressBookProtos.java:43
↓ 4 callersMethodgetMessage
()
wrangler-core/src/test/java/co/cask/wrangler/clients/SchemaRegistryClientTest.java:88
↓ 4 callersMethodgetMetrics
@return Measurements handler.
wrangler-api/src/main/java/co/cask/wrangler/api/ExecutorContext.java:50
↓ 4 callersMethodgetRecipe
@return Recipe specification associated with the request.
wrangler-service/src/main/java/co/cask/wrangler/proto/Request.java:43
↓ 4 callersMethodgetValues
@return List of the objects of type T.
wrangler-core/src/main/java/co/cask/wrangler/clients/Response.java:67
↓ 4 callersMethodinitialize
Configures the pipeline based on the directives. It parses the recipe, converting it into executable directives. @param parser Wrangle directives par
wrangler-core/src/main/java/co/cask/wrangler/executor/RecipePipelineExecutor.java:59
↓ 4 callersMethodisDate
Detect if the given value is a date type. <br> @param value the value to be detected. @return true if the value is a date type, false otherwise.
wrangler-core/src/main/java/co/cask/wrangler/dq/TypeInference.java:133
↓ 4 callersMethodisDouble
Detect if the given value is a double type. <p> Note:<br> 1. This method support only English locale.<br> e.g. {@code TypeInference.isDouble("3.4")}
wrangler-core/src/main/java/co/cask/wrangler/dq/TypeInference.java:69
↓ 4 callersMethodloadAndExecute
Loads the driver and gets the connection to the database. @param id of the connection to be connected to. @return pair of connection and the driver c
wrangler-service/src/main/java/co/cask/wrangler/service/database/DatabaseService.java:679
↓ 4 callersMethodloadLocalFile
(String path)
wrangler-service/src/main/java/co/cask/wrangler/service/gcp/GCPUtils.java:42
↓ 4 callersMethodm
()
wrangler-core/src/main/java/co/cask/directives/nlp/internal/PorterStemmer.java:153
↓ 4 callersMethodparseFrom
( com.google.protobuf.ByteString data)
wrangler-core/src/test/java/com/example/tutorial/AddressBookProtos.java:1086
↓ 4 callersMethodremove
Unsupported. @throws UnsupportedOperationException always
wrangler-service/src/main/java/co/cask/wrangler/service/explorer/BoundedLineInputStream.java:160
↓ 4 callersMethodreset
Resets the state of this store.
wrangler-api/src/main/java/co/cask/wrangler/api/TransientStore.java:31
↓ 4 callersMethodscan
Scans the namespace to list all the keys applying the filter. @param filter to be applied on the data being returned. @return List of objects of type
wrangler-service/src/main/java/co/cask/wrangler/dataset/AbstractTableStore.java:212
↓ 4 callersMethodsetUpdated
Sets the last updated date time in second for the connection. @param updated date time for the connection.
wrangler-service/src/main/java/co/cask/wrangler/dataset/connections/Connection.java:171
↓ 4 callersMethodstart
()
wrangler-service/src/test/java/co/cask/wrangler/service/database/DatabaseServiceTest.java:246
↓ 4 callersMethodtoObject
Converts a serialized object byte array back into object. @param bytes to be converted to object of type T. @return an instance of object deserialize
wrangler-core/src/main/java/co/cask/wrangler/utils/ObjectSerDe.java:65
↓ 4 callersMethodvalidateConnection
(String inputConnectionId, Connection connection)
wrangler-service/src/main/java/co/cask/wrangler/service/spanner/SpannerService.java:379
↓ 3 callersMethodapply
(Row row)
wrangler-transform/src/main/java/co/cask/wrangler/Precondition.java:48
↓ 3 callersMethodbuildPartial
()
wrangler-core/src/test/java/com/example/tutorial/AddressBookProtos.java:1236
↓ 3 callersMethodcompile
(String expression)
wrangler-core/src/main/java/co/cask/wrangler/expression/EL.java:64
↓ 3 callersMethodcompileSuccess
(String[] recipe)
wrangler-core/src/test/java/co/cask/wrangler/TestingRig.java:140
↓ 3 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-core/src/main/java/co/cask/wrangler/parser/MapArguments.java:151
↓ 3 callersMethoddecodeRecord
Converts a Wrangler {@link Row} into a {@link StructuredRecord}. @param row defines a single {@link Row} @param schema Schema associated with {@link
wrangler-core/src/main/java/co/cask/wrangler/utils/RecordConvertor.java:69
↓ 3 callersMethoddestroy
This method provides a way for the directive to de-initialize or destroy the resources that were acquired during the initialization phase. This method
wrangler-api/src/main/java/co/cask/wrangler/api/Executor.java:79
↓ 3 callersMethodexecute
Executes the pipeline on the input. @param rows List of Input record of type I. @param schema Schema to which the output should be mapped. @return Pa
wrangler-core/src/main/java/co/cask/wrangler/executor/RecipePipelineExecutor.java:95
↓ 3 callersMethodexecute
(ELContext context, boolean nullMissingFields)
wrangler-core/src/main/java/co/cask/wrangler/expression/EL.java:87
↓ 3 callersMethodexecuteDirectives
Executes directives by extracting them from request. @param id data to be used for executing directives. @param user request passed on http. @param s
wrangler-service/src/main/java/co/cask/wrangler/service/directive/DirectivesService.java:1212
↓ 3 callersMethodfromString
Converts the string representation of type into a {@link DataType}. @param text representation of the type. @return an instance of {@link DataType} b
wrangler-service/src/main/java/co/cask/wrangler/dataset/workspace/DataType.java:53
↓ 3 callersMethodget
(int i)
wrangler-api/src/main/java/co/cask/wrangler/api/TokenGroup.java:50
↓ 3 callersMethodget
@return Kafka connection property.
wrangler-service/src/main/java/co/cask/wrangler/service/kafka/KafkaConfiguration.java:136
↓ 3 callersMethodgetCode
@return Code associated with the error.
wrangler-api/src/main/java/co/cask/wrangler/api/ErrorRecord.java:58
↓ 3 callersMethodgetConnection
@return connection information of kafka.
wrangler-service/src/main/java/co/cask/wrangler/service/kafka/KafkaConfiguration.java:129
↓ 3 callersMethodgetConnectionId
Get connection id for the given connection name @param name name of the connection. @return connection id.
wrangler-service/src/main/java/co/cask/wrangler/dataset/AbstractTableStore.java:173
↓ 3 callersMethodgetCount
@return Count of objects within the list.
wrangler-core/src/main/java/co/cask/wrangler/clients/Response.java:60
↓ 3 callersMethodgetDate
(Row row, String colName)
wrangler-core/src/main/java/co/cask/directives/date/DiffDate.java:89
← previousnext →101–200 of 1,973, ranked by callers