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
↓ 2 callers
Method
getUrl
()
wrangler-proto/src/main/java/io/cdap/wrangler/proto/schema/DataModelUrlRequest.java:31
↓ 2 callers
Method
getVersions
(HttpRequest request, HttpResponder responder, @PathParam("context") String context)
wrangler-core/src/test/java/io/cdap/wrangler/clients/SchemaRegistryClientTest.java:141
↓ 2 callers
Method
getWeight
()
wrangler-core/src/main/java/io/cdap/wrangler/sampling/Reservoir.java:131
↓ 2 callers
Method
getWorkspace
()
wrangler-proto/src/main/java/io/cdap/wrangler/proto/workspace/v2/WorkspaceDetail.java:54
↓ 2 callers
Method
getWorkspaceSummary
Get the summary for the workspace rows
wrangler-service/src/main/java/io/cdap/wrangler/service/directive/AbstractDirectiveHandler.java:220
↓ 2 callers
Method
hasAlias
Checks if the directive is aliased. @param directive to be checked for aliasing. @return true if the directive has an alias, false otherwise.
wrangler-api/src/main/java/io/cdap/wrangler/api/DirectiveAlias.java:31
↓ 2 callers
Method
init
(HandlerContext handlerContext)
wrangler-core/src/test/java/io/cdap/directives/external/InvokeHttpTest.java:67
↓ 2 callers
Method
init
(ExecutorContext context)
wrangler-core/src/main/java/io/cdap/wrangler/expression/ELContext.java:94
↓ 2 callers
Method
initClientReturnResponse
(ADLStoreClient client, String path)
wrangler-service/src/main/java/io/cdap/wrangler/service/adls/ADLSHandler.java:172
↓ 2 callers
Method
isDateTime
(List<Map<Pattern, String>> patternGroupList, String value)
wrangler-core/src/main/java/io/cdap/wrangler/dq/DateTimePattern.java:105
↓ 2 callers
Method
isLeft
(Coordinates vertex0, Coordinates vertex1, Coordinates gpC)
wrangler-core/src/main/java/io/cdap/functions/GeoFences.java:117
↓ 2 callers
Method
iterator
Returns an iterator to the list of token groups maintained by this object. @return iterator to the list of tokens maintained.
wrangler-api/src/main/java/io/cdap/wrangler/api/RecipeSymbol.java:112
↓ 2 callers
Method
keysToLower
This function lowers the keys of the json. it applies this transformation recurively. @param element to be transformed. @return modified element.
wrangler-core/src/main/java/io/cdap/functions/JsonFunctions.java:144
↓ 2 callers
Method
label
@return Label associated with the token. Label provides a way to override the usage description for this <code>TokenDefinition</code>. If a label is n
wrangler-api/src/main/java/io/cdap/wrangler/api/parser/TokenDefinition.java:61
↓ 2 callers
Method
line
Returns the source line number these arguments were parsed from. @return the source line number.
wrangler-api/src/main/java/io/cdap/wrangler/api/Arguments.java:92
↓ 2 callers
Method
list
@return Returns an iterator to iterate through all the <code>DirectiveInfo</code> objects maintained within the registry.
wrangler-core/src/main/java/io/cdap/wrangler/registry/CompositeDirectiveRegistry.java:95
↓ 2 callers
Method
list
Scans the namespace to list all the keys applying the filter. @param filter to be applied on the data being returned. @return List of connections
wrangler-storage/src/main/java/io/cdap/wrangler/dataset/connections/ConnectionStore.java:193
↓ 2 callers
Method
listDatasets
(HttpServiceRequest request, HttpServiceResponder responder, @PathParam("context")
wrangler-service/src/main/java/io/cdap/wrangler/service/bigquery/BigQueryHandler.java:130
↓ 2 callers
Method
listWorkspaces
Lists all the workspaces registered for a scope. @return List of workspaces.
wrangler-storage/src/main/java/io/cdap/wrangler/dataset/workspace/WorkspaceDataset.java:193
↓ 2 callers
Method
loadDrivers
(InputStream is, Map<String, DriverInfo> drivers)
wrangler-service/src/main/java/io/cdap/wrangler/service/database/DatabaseHandler.java:160
↓ 2 callers
Method
loadPatterns
(String patternFileName, List<Map<Pattern, String>> patternParsers)
wrangler-core/src/main/java/io/cdap/wrangler/dq/DateTimePattern.java:46
↓ 2 callers
Method
lookup
Looks up the code in the catalog. @param code to be looked up. @return StaticCatalog entry if found, else null.
wrangler-core/src/main/java/io/cdap/directives/lookup/StaticCatalog.java:41
↓ 2 callers
Method
matchPattern
(String value)
wrangler-core/src/main/java/io/cdap/directives/row/RecordRegexFilter.java:143
↓ 2 callers
Method
murmurHash
This function hashes an integer value. It is crucial to use different hash functions to partition data and the internal partitioning of data structur
wrangler-core/src/main/java/io/cdap/wrangler/sampling/MathUtils.java:33
↓ 2 callers
Method
nextLine
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:132
↓ 2 callers
Method
parser
()
wrangler-core/src/test/java/com/example/tutorial/AddressBookProtos.java:1807
↓ 2 callers
Method
percentage
Computes percentages for each measure for a given column. @param column name of the column. @param sum denonminator for calculating percentages. @ret
wrangler-core/src/main/java/io/cdap/wrangler/statistics/ColumnMetric.java:82
↓ 2 callers
Method
precision
Get the precision of a decimal value
wrangler-core/src/main/java/io/cdap/wrangler/utils/DecimalTransform.java:98
↓ 2 callers
Method
process
(List<String> input)
wrangler-core/src/main/java/io/cdap/directives/nlp/internal/PorterStemmer.java:625
↓ 2 callers
Method
readArray
(JsonArray array, String path)
wrangler-core/src/main/java/io/cdap/wrangler/utils/JsonPathGenerator.java:98
↓ 2 callers
Method
readResource
(String name)
wrangler-core/src/main/java/io/cdap/directives/validation/ValidateStandard.java:99
↓ 2 callers
Method
rename
Renames a column. The renamed column must not exist in the row. The comparision is case insensitive. @param row source record to be modified. @param
wrangler-core/src/main/java/io/cdap/wrangler/utils/ColumnConverter.java:49
↓ 2 callers
Method
retrieveSample
(String namespace, String connectionName, SampleRequest sampleRequest)
wrangler-service/src/main/java/io/cdap/wrangler/service/directive/ConnectionDiscoverer.java:103
↓ 2 callers
Method
samplingProcess
()
wrangler-core/src/main/java/io/cdap/wrangler/sampling/Poisson.java:138
↓ 2 callers
Method
saveRecipe
(RecipeId recipeId, RecipeRow recipeRow, boolean failIfNotFound, StructuredTable table)
wrangler-storage/src/main/java/io/cdap/wrangler/store/recipe/RecipeStore.java:127
↓ 2 callers
Method
setCanWrangle
(boolean canWrangle)
wrangler-proto/src/main/java/io/cdap/wrangler/proto/s3/S3ObjectInfo.java:114
↓ 2 callers
Method
setComplete
(NamespaceSummary namespace, StructuredTableContext context, UpgradeEntityType type
wrangler-storage/src/main/java/io/cdap/wrangler/store/upgrade/UpgradeStore.java:152
↓ 2 callers
Method
setDescription
(String description)
wrangler-proto/src/main/java/io/cdap/wrangler/proto/connection/ConnectionMeta.java:123
↓ 2 callers
Method
setDisplaySize
(long displaySize)
wrangler-proto/src/main/java/io/cdap/wrangler/proto/adls/ADLSDirectoryEntryInfo.java:91
↓ 2 callers
Method
setField
( com.google.protobuf.Descriptors.FieldDescriptor field, Object value)
wrangler-core/src/test/java/com/example/tutorial/AddressBookProtos.java:1260
↓ 2 callers
Method
setGroup
(String group)
wrangler-proto/src/main/java/io/cdap/wrangler/proto/adls/ADLSDirectoryEntryInfo.java:86
↓ 2 callers
Method
setId
<pre> Unique ID number for this person. </pre> <code>int32 id = 2;</code>
wrangler-core/src/test/java/com/example/tutorial/AddressBookProtos.java:1445
↓ 2 callers
Method
setInsights
(JsonObject insights)
wrangler-proto/src/main/java/io/cdap/wrangler/proto/workspace/v2/Workspace.java:157
↓ 2 callers
Method
setName
(String name)
wrangler-proto/src/main/java/io/cdap/wrangler/proto/connection/ConnectionMeta.java:118
↓ 2 callers
Method
setOwner
(String owner)
wrangler-proto/src/main/java/io/cdap/wrangler/proto/s3/S3ObjectInfo.java:84
↓ 2 callers
Method
setPermission
(String permission)
wrangler-proto/src/main/java/io/cdap/wrangler/proto/adls/ADLSDirectoryEntryInfo.java:101
↓ 2 callers
Method
setPreconfigured
(boolean preconfigured)
wrangler-proto/src/main/java/io/cdap/wrangler/proto/connection/Connection.java:163
↓ 2 callers
Method
setProperties
(Map<String, String> properties)
wrangler-proto/src/main/java/io/cdap/wrangler/proto/connection/ConnectionMeta.java:128
↓ 2 callers
Method
setRepeatedField
( com.google.protobuf.Descriptors.FieldDescriptor field, int index, Object value)
wrangler-core/src/test/java/com/example/tutorial/AddressBookProtos.java:1273
↓ 2 callers
Method
setType
(ConnectionType type)
wrangler-proto/src/main/java/io/cdap/wrangler/proto/connection/ConnectionMeta.java:113
↓ 2 callers
Method
setUser
(String user)
wrangler-proto/src/main/java/io/cdap/wrangler/proto/adls/ADLSDirectoryEntryInfo.java:81
↓ 2 callers
Method
toFields
(Connection connection, long generation)
wrangler-storage/src/main/java/io/cdap/wrangler/dataset/connections/ConnectionStore.java:251
↓ 2 callers
Method
toFields
(SchemaRow schemaRow)
wrangler-storage/src/main/java/io/cdap/wrangler/dataset/schema/SchemaRegistry.java:359
↓ 2 callers
Method
toJsonString
Converts a {@link StructuredRecord} to a json string.
wrangler-core/src/main/java/io/cdap/wrangler/utils/StructuredRecordJsonConverter.java:67
↓ 2 callers
Method
updateWorkspace
Save the new workspace metadata @param workspaceId the workspace id @param workspace the new workspace meta to save
wrangler-storage/src/main/java/io/cdap/wrangler/store/workspace/WorkspaceStore.java:164
↓ 2 callers
Method
validate
Should be called if this object is created through deserialization of user input. @throws IllegalArgumentException if the object is invalid.
wrangler-proto/src/main/java/io/cdap/wrangler/proto/connection/ConnectionMeta.java:62
↓ 2 callers
Method
validateNamespace
(NamespaceSummary ns, String errorMessage)
wrangler-service/src/main/java/io/cdap/wrangler/service/directive/WorkspaceHandler.java:461
↓ 2 callers
Method
validatePrecondition
(String precondition, Boolean isConditionSQL, FailureCollector collector)
wrangler-transform/src/main/java/io/cdap/wrangler/Wrangler.java:546
↓ 2 callers
Method
value
This method returns the token {@code value} based on the {@code name} specified in the argument. This method will attempt to convert the token into th
wrangler-core/src/main/java/io/cdap/wrangler/parser/MapArguments.java:167
↓ 2 callers
Method
value
()
wrangler-api/src/main/java/io/cdap/wrangler/api/parser/ColumnNameList.java:39
↓ 2 callers
Method
value
()
wrangler-api/src/main/java/io/cdap/wrangler/api/parser/Text.java:34
↓ 2 callers
Method
value
()
wrangler-api/src/main/java/io/cdap/wrangler/api/parser/Expression.java:34
↓ 2 callers
Method
verify
(Class<? extends Directive> directive)
wrangler-test/src/main/java/io/cdap/wrangler/test/TestingRig.java:75
↓ 2 callers
Method
vowelinstem
()
wrangler-core/src/main/java/io/cdap/directives/nlp/internal/PorterStemmer.java:205
↓ 1 callers
Method
CurrentTime
@return return current localtime.
wrangler-core/src/main/java/io/cdap/functions/DateAndTime.java:160
↓ 1 callers
Method
IsNotNull
Returns true when an expression does not evaluate to the null value. @param value to be evaluated. @return true when not null, false otherwise.
wrangler-core/src/main/java/io/cdap/functions/Global.java:226
↓ 1 callers
Method
MicroSecondsFromTime
Returns the microsecond portion of a time. If time is null, null will be returned. @param time of {@link LocalTime} type. @return microsecond portion
wrangler-core/src/main/java/io/cdap/functions/DateAndTime.java:356
↓ 1 callers
Method
NanoSecondsFromTime
Returns the Nanosecond portion of a time. If time is null, null will be returned. @param time of {@link LocalTime} type. @return nanosecond portion o
wrangler-core/src/main/java/io/cdap/functions/DateAndTime.java:346
↓ 1 callers
Method
Parse
Parses a column or string to JSON. If the json string is invalid, this method will return a JsonNull @param json string representation of json. @retu
wrangler-core/src/main/java/io/cdap/functions/JsonFunctions.java:236
↓ 1 callers
Method
acquire
()
wrangler-service/src/main/java/io/cdap/wrangler/service/explorer/DatasetProvider.java:27
↓ 1 callers
Method
addConnection
(String namespace, String connectionName, ConnectionCreationRequest request)
wrangler-service/src/main/java/io/cdap/wrangler/service/directive/ConnectionDiscoverer.java:75
↓ 1 callers
Method
addDefaultDirectives
Loads all the default system directives that are available with the system.
wrangler-core/src/main/java/io/cdap/wrangler/parser/UsageRegistry.java:144
↓ 1 callers
Method
addLoadableDirective
A Recipe can specify the pragma instructions for loading the directives dynamically. This method allows adding the new directive to be loaded as it's
wrangler-api/src/main/java/io/cdap/wrangler/api/RecipeSymbol.java:216
↓ 1 callers
Method
addNewOutputFields
Method to add new fields from the given output to the map of fieldName --> value maintained for schema generation. A value is added to the map only if
wrangler-core/src/main/java/io/cdap/wrangler/schema/DirectiveOutputSchemaGenerator.java:54
↓ 1 callers
Method
addOrSetAtIndex
Adds or sets the value to the beginning. @param index at which the column need to be inserted. @param name of the field to be either set or added to
wrangler-api/src/main/java/io/cdap/wrangler/api/Row.java:233
↓ 1 callers
Method
addPeople
<code>repeated .tutorial.Person people = 1;</code>
wrangler-core/src/test/java/com/example/tutorial/AddressBookProtos.java:2353
↓ 1 callers
Method
addPhones
<code>repeated .tutorial.Person.PhoneNumber phones = 4;</code>
wrangler-core/src/test/java/com/example/tutorial/AddressBookProtos.java:1610
↓ 1 callers
Method
addVersion
Recipe can specify the version of the grammar. This method allows one to extract and add the version to the <code>RecipeSymbol.</code> @param version
wrangler-api/src/main/java/io/cdap/wrangler/api/RecipeSymbol.java:205
↓ 1 callers
Method
bitMix
Bit-mixing for pseudo-randomization of integers (e.g., to guard against bad hash functions). Implementation is from Murmur's 32 bit finalizer. @param
wrangler-core/src/main/java/io/cdap/wrangler/sampling/MathUtils.java:60
↓ 1 callers
Method
calcHash
(InputStream is)
wrangler-core/src/test/java/io/cdap/directives/validation/ValidateStandardTest.java:80
↓ 1 callers
Method
checkConformance
Validate the given value against the loaded schema. It is up to the implementation to decide whether to return the first occurring error or all at onc
wrangler-core/src/main/java/io/cdap/directives/validation/conformers/Conformer.java:48
↓ 1 callers
Method
checkIfRowIsEmpty
(org.apache.poi.ss.usermodel.Row row)
wrangler-core/src/main/java/io/cdap/directives/parser/ParseExcel.java:232
↓ 1 callers
Method
clientInputStream
(ADLStoreClient client, FileQueryDetails fileQueryDetails)
wrangler-service/src/main/java/io/cdap/wrangler/service/adls/ADLSHandler.java:271
↓ 1 callers
Method
columnName
(int number)
wrangler-core/src/main/java/io/cdap/directives/parser/ParseExcel.java:248
↓ 1 callers
Method
configure
(HttpURLConnection urlConn)
wrangler-service/src/main/java/io/cdap/wrangler/service/directive/ConnectionDiscoverer.java:226
↓ 1 callers
Method
connectionExists
Returns true if connection identified by connectionName already exists.
wrangler-storage/src/main/java/io/cdap/wrangler/dataset/connections/ConnectionStore.java:183
↓ 1 callers
Method
convertKey
(String key, Schema.Type type)
wrangler-core/src/main/java/io/cdap/wrangler/utils/StructuredRecordJsonConverter.java:154
↓ 1 callers
Method
convertResultSetToRow
(ResultSet resultSet)
wrangler-service/src/main/java/io/cdap/wrangler/service/spanner/SpannerHandler.java:338
↓ 1 callers
Method
convertToBytes
(List<Row> sample)
wrangler-proto/src/main/java/io/cdap/wrangler/proto/workspace/v2/WorkspaceDetail.java:43
↓ 1 callers
Method
createGCSBucketWithFile
(String filePath)
wrangler-transform/src/e2e-test/java/io/cdap/plugin/common/stepsdesign/TestSetupHooks.java:148
↓ 1 callers
Method
createSortByMap
()
wrangler-storage/src/main/java/io/cdap/wrangler/dataset/recipe/RecipePageRequest.java:117
↓ 1 callers
Method
createTestTables
(Connection conn)
wrangler-service/src/test/java/io/cdap/wrangler/service/database/DatabaseHandlerTest.java:149
↓ 1 callers
Method
createTestUser
(Connection conn)
wrangler-service/src/test/java/io/cdap/wrangler/service/database/DatabaseHandlerTest.java:143
↓ 1 callers
Method
createTokenGroup
<code>TokenGroup</code> is created for each directive in the recipe. This method creates a new <code>TokenGroup</code> by passing the <code>SourceInfo
wrangler-api/src/main/java/io/cdap/wrangler/api/RecipeSymbol.java:183
↓ 1 callers
Method
decode
Decodes byte array of binary encoded AVRO into list of {@link Row}. This method will iterate through each of the AVRO schema fields and translate them
wrangler-core/src/main/java/io/cdap/wrangler/codec/BinaryAvroDecoder.java:58
↓ 1 callers
Method
decode
(byte[] bytes)
wrangler-core/src/main/java/io/cdap/wrangler/codec/ProtobufDecoderUsingDescriptor.java:50
↓ 1 callers
Method
decodeMap
(String name, Map<Object, Object> object, Schema key, Schema value)
wrangler-core/src/main/java/io/cdap/wrangler/utils/RecordConvertor.java:413
↓ 1 callers
Method
decodeMessage
(Message message, Row row, String root)
wrangler-core/src/main/java/io/cdap/wrangler/codec/ProtobufDecoderUsingDescriptor.java:64
↓ 1 callers
Method
decodeSimpleTypes
(String name, Object object, Schema schema)
wrangler-core/src/main/java/io/cdap/wrangler/utils/RecordConvertor.java:254
↓ 1 callers
Method
decodeUnion
(String name, Object object, List<Schema> schemas)
wrangler-core/src/main/java/io/cdap/wrangler/utils/RecordConvertor.java:423
← previous
next →
601–700 of 3,047, ranked by callers