Code
Hub
Workspaces
Following
Trending
Connect
MCP
copy
Create free account
hub
/
github.com/data-integrations/wrangler
/ functions
Functions
1,973 in github.com/data-integrations/wrangler
⨍
Functions
1,973
◇
Types & classes
423
↓ 7 callers
Method
decode
(byte[] bytes)
wrangler-core/src/main/java/co/cask/wrangler/codec/Decoder.java:26
↓ 7 callers
Method
getBoolean
()
wrangler-core/src/main/java/co/cask/wrangler/expression/ELResult.java:33
↓ 7 callers
Method
getProp
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 callers
Method
join
(JsonElement element, String separator)
wrangler-core/src/main/java/co/cask/functions/JSON.java:151
↓ 7 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/co/cask/wrangler/api/LazyNumber.java:58
↓ 7 callers
Method
migrate
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 callers
Method
notFound
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 callers
Method
removeRepeatedChar
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 callers
Method
set
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 callers
Method
close
()
wrangler-core/src/test/java/co/cask/wrangler/registry/CompositeDirectiveRegistryTest.java:115
↓ 6 callers
Method
compileFailure
(String[] recipe)
wrangler-core/src/test/java/co/cask/wrangler/TestingRig.java:145
↓ 6 callers
Method
detectFileType
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 callers
Method
getDateTime
(ZonedDateTime zonedDateTime)
wrangler-core/src/main/java/co/cask/functions/Dates.java:287
↓ 6 callers
Method
getDescription
()
wrangler-core/src/main/java/co/cask/directives/lookup/StaticCatalog.java:52
↓ 6 callers
Method
getHeader
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 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
↓ 6 callers
Method
getLocation
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 callers
Method
getNumber
<code>string number = 1;</code>
wrangler-core/src/test/java/com/example/tutorial/AddressBookProtos.java:287
↓ 6 callers
Method
getPort
()
wrangler-service/src/main/java/co/cask/wrangler/service/database/DatabaseService.java:185
↓ 6 callers
Method
getSchema
()
wrangler-service/src/main/java/co/cask/wrangler/service/common/Format.java:33
↓ 6 callers
Method
getService
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 callers
Method
getVariables
Set of all the variables. @return list of all the variables.
wrangler-api/src/main/java/co/cask/wrangler/api/TransientStore.java:63
↓ 6 callers
Method
parse
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 callers
Method
setColumn
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 callers
Method
setValue
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 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/co/cask/wrangler/api/parser/Token.java:50
↓ 5 callers
Method
Identifier
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 callers
Method
ends
(String s)
wrangler-core/src/main/java/co/cask/directives/nlp/internal/PorterStemmer.java:208
↓ 5 callers
Method
ensurePeopleIsMutable
()
wrangler-core/src/test/java/com/example/tutorial/AddressBookProtos.java:2279
↓ 5 callers
Method
ensurePhonesIsMutable
()
wrangler-core/src/test/java/com/example/tutorial/AddressBookProtos.java:1536
↓ 5 callers
Method
generateKey
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 callers
Method
getAliasName
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 callers
Method
getDirectives
@return List of directives that is part of recipe.
wrangler-service/src/main/java/co/cask/wrangler/service/recipe/RecipeDatum.java:117
↓ 5 callers
Method
getPeopleFieldBuilder
()
wrangler-core/src/test/java/com/example/tutorial/AddressBookProtos.java:2502
↓ 5 callers
Method
getPhonesFieldBuilder
()
wrangler-core/src/test/java/com/example/tutorial/AddressBookProtos.java:1759
↓ 5 callers
Method
getSpannerService
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 callers
Method
getTransientStore
@return A transient store.
wrangler-api/src/main/java/co/cask/wrangler/api/ExecutorContext.java:74
↓ 5 callers
Method
initialize
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 callers
Method
isExcluded
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 callers
Method
isInteger
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 callers
Method
isSuccess
()
wrangler-api/src/main/java/co/cask/wrangler/api/CompileStatus.java:44
↓ 5 callers
Method
now
@return current time in seconds.
wrangler-service/src/main/java/co/cask/wrangler/dataset/AbstractTableStore.java:185
↓ 5 callers
Method
readJson
(JsonReader reader, Schema schema)
wrangler-core/src/main/java/co/cask/wrangler/utils/StructuredRecordJsonConverter.java:142
↓ 5 callers
Method
stop
()
wrangler-service/src/test/java/co/cask/wrangler/service/database/DatabaseServiceTest.java:252
↓ 5 callers
Method
toArray
()
wrangler-test/src/main/java/co/cask/wrangler/test/api/TestRecipe.java:40
↓ 5 callers
Method
toSchema
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 callers
Method
toVersionColumn
(long version)
wrangler-service/src/main/java/co/cask/wrangler/dataset/schema/SchemaRegistry.java:344
↓ 5 callers
Method
validate
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 callers
Method
writeJson
(JsonWriter writer, Schema schema, Object value)
wrangler-core/src/main/java/co/cask/wrangler/utils/StructuredRecordJsonConverter.java:281
↓ 4 callers
Method
add
(Row row)
wrangler-test/src/main/java/co/cask/wrangler/test/api/TestRows.java:34
↓ 4 callers
Method
cons
(int i)
wrangler-core/src/main/java/co/cask/directives/nlp/internal/PorterStemmer.java:135
↓ 4 callers
Method
convertField
(Object field, Schema fieldSchema)
wrangler-core/src/main/java/co/cask/wrangler/utils/StructuredRecordConverter.java:98
↓ 4 callers
Method
debug
(Object o)
wrangler-core/src/main/java/co/cask/wrangler/expression/EL.java:150
↓ 4 callers
Method
decode
(String name, Object object, Schema schema)
wrangler-core/src/main/java/co/cask/wrangler/utils/RecordConvertor.java:110
↓ 4 callers
Method
destroy
()
wrangler-service/src/main/java/co/cask/wrangler/service/database/DriverCleanup.java:33
↓ 4 callers
Method
executeWithErrors
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 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/co/cask/wrangler/api/LazyNumber.java:74
↓ 4 callers
Method
fromString
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 callers
Method
getBigQueryService
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 callers
Method
getColumns
@return Set of columns tracked.
wrangler-core/src/main/java/co/cask/wrangler/statistics/ColumnMetric.java:71
↓ 4 callers
Method
getConnection
()
wrangler-service/src/test/java/co/cask/wrangler/service/database/DatabaseServiceTest.java:228
↓ 4 callers
Method
getData
(Connection connection, TableId tableId)
wrangler-service/src/main/java/co/cask/wrangler/service/bigquery/BigQueryService.java:344
↓ 4 callers
Method
getDatasetId
(String datasetStr, String connectionProject)
wrangler-service/src/main/java/co/cask/wrangler/service/bigquery/BigQueryService.java:538
↓ 4 callers
Method
getEmail
<code>string email = 3;</code>
wrangler-core/src/test/java/com/example/tutorial/AddressBookProtos.java:43
↓ 4 callers
Method
getMessage
()
wrangler-core/src/test/java/co/cask/wrangler/clients/SchemaRegistryClientTest.java:88
↓ 4 callers
Method
getMetrics
@return Measurements handler.
wrangler-api/src/main/java/co/cask/wrangler/api/ExecutorContext.java:50
↓ 4 callers
Method
getRecipe
@return Recipe specification associated with the request.
wrangler-service/src/main/java/co/cask/wrangler/proto/Request.java:43
↓ 4 callers
Method
getValues
@return List of the objects of type T.
wrangler-core/src/main/java/co/cask/wrangler/clients/Response.java:67
↓ 4 callers
Method
initialize
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 callers
Method
isDate
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 callers
Method
isDouble
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 callers
Method
loadAndExecute
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 callers
Method
loadLocalFile
(String path)
wrangler-service/src/main/java/co/cask/wrangler/service/gcp/GCPUtils.java:42
↓ 4 callers
Method
m
()
wrangler-core/src/main/java/co/cask/directives/nlp/internal/PorterStemmer.java:153
↓ 4 callers
Method
parseFrom
( com.google.protobuf.ByteString data)
wrangler-core/src/test/java/com/example/tutorial/AddressBookProtos.java:1086
↓ 4 callers
Method
remove
Unsupported. @throws UnsupportedOperationException always
wrangler-service/src/main/java/co/cask/wrangler/service/explorer/BoundedLineInputStream.java:160
↓ 4 callers
Method
reset
Resets the state of this store.
wrangler-api/src/main/java/co/cask/wrangler/api/TransientStore.java:31
↓ 4 callers
Method
scan
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 callers
Method
setUpdated
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 callers
Method
start
()
wrangler-service/src/test/java/co/cask/wrangler/service/database/DatabaseServiceTest.java:246
↓ 4 callers
Method
toObject
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 callers
Method
validateConnection
(String inputConnectionId, Connection connection)
wrangler-service/src/main/java/co/cask/wrangler/service/spanner/SpannerService.java:379
↓ 3 callers
Method
apply
(Row row)
wrangler-transform/src/main/java/co/cask/wrangler/Precondition.java:48
↓ 3 callers
Method
buildPartial
()
wrangler-core/src/test/java/com/example/tutorial/AddressBookProtos.java:1236
↓ 3 callers
Method
compile
(String expression)
wrangler-core/src/main/java/co/cask/wrangler/expression/EL.java:64
↓ 3 callers
Method
compileSuccess
(String[] recipe)
wrangler-core/src/test/java/co/cask/wrangler/TestingRig.java:140
↓ 3 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-core/src/main/java/co/cask/wrangler/parser/MapArguments.java:151
↓ 3 callers
Method
decodeRecord
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 callers
Method
destroy
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 callers
Method
execute
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 callers
Method
execute
(ELContext context, boolean nullMissingFields)
wrangler-core/src/main/java/co/cask/wrangler/expression/EL.java:87
↓ 3 callers
Method
executeDirectives
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 callers
Method
fromString
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 callers
Method
get
(int i)
wrangler-api/src/main/java/co/cask/wrangler/api/TokenGroup.java:50
↓ 3 callers
Method
get
@return Kafka connection property.
wrangler-service/src/main/java/co/cask/wrangler/service/kafka/KafkaConfiguration.java:136
↓ 3 callers
Method
getCode
@return Code associated with the error.
wrangler-api/src/main/java/co/cask/wrangler/api/ErrorRecord.java:58
↓ 3 callers
Method
getConnection
@return connection information of kafka.
wrangler-service/src/main/java/co/cask/wrangler/service/kafka/KafkaConfiguration.java:129
↓ 3 callers
Method
getConnectionId
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 callers
Method
getCount
@return Count of objects within the list.
wrangler-core/src/main/java/co/cask/wrangler/clients/Response.java:60
↓ 3 callers
Method
getDate
(Row row, String colName)
wrangler-core/src/main/java/co/cask/directives/date/DiffDate.java:89
← previous
next →
101–200 of 1,973, ranked by callers