Comments (2)
I updated the chunked example, which had bad code for the read.
Regarding the write path are you reading chunks for a single file from a single HTTP request or can you get the chunks out of order via multiple requests (kinda like S3). For the former, you could use ChunkedInputStream to bridge the chunked http request and the object store API. You can use a high concurrency level in the ObjectWriter by calling withConcurrencyLevel() to speed up writing to cassandra. If you use this with token aware and have a lot of connections in your pool then you'd be able to get through the chunks quickly.
There is no callback in the API. It just returns the ObjectMetadata if the write was successful or throws an exception if not. It will do proper cleanup if it does fail to write the entire block.
from astyanax.
sweeeeet, love the cleanup part(was wondering about that). I have a question on the threading model though.
Isn't it asynchronous writes to cassandra(though on stackoverflow, you said thrift can't do asynchornous though I thought it could these days)...ie. I want to avoid write(1ms delay to response))write(another 1ms) write 1000 more times and have 1000ms. Of course, having 10 threads brings this to 100ms. BUT I heard thrift has an asycnhronous now so wouldn't it be better to write, write, write, receive request, receive request, etc. etc. (ie. do all the writes up front with no waiting for the response). That would be perfect.
from astyanax.
Related Issues (20)
- Starting an CqlKeyspace while all hosts are down results to empty session (Using JavaDriver) HOT 1
- plan to support cassandra 2.1 and on HOT 1
- java.lang.NoSuchMethodError: com.google.common.cache.CacheBuilder.build()Lcom/google/common/cache/Cache; HOT 4
- Error while Shutting down tomcat while using astyanax library
- Remove log4j.xml from astyanax-core HOT 1
- read a part of object with chunked object store
- BadRequestException: Object Chunk storeage - InvalidRequestException - Astyanax
- Update DataStax version
- Update Cassandra Compatibility page
- Unexpected extraneous bytes after set value
- NodeDiscovery threads have non-unique name
- Cassandra Credentails
- Question regarding testGetAllKeysRoot method in ThriftKeyspaceImplTest.java HOT 1
- Nodes unreachable when upgrading from 2.2.5 to 3.0.9 on aws ec2snitch
- Wiki mentions DC Aware policy, but no such policy is defined in astyanax code
- Note that Astyanax is being retired? HOT 1
- API changes review for Astyanax Core
- astyanax-cql ships with version of Netty with known vulnerabilily HOT 1
- schema update
- https://github.com/Netflix/astyanax/wiki/Chunked-Object-Store
Recommend Projects
-
React
A declarative, efficient, and flexible JavaScript library for building user interfaces.
-
Vue.js
🖖 Vue.js is a progressive, incrementally-adoptable JavaScript framework for building UI on the web.
-
Typescript
TypeScript is a superset of JavaScript that compiles to clean JavaScript output.
-
TensorFlow
An Open Source Machine Learning Framework for Everyone
-
Django
The Web framework for perfectionists with deadlines.
-
Laravel
A PHP framework for web artisans
-
D3
Bring data to life with SVG, Canvas and HTML. 📊📈🎉
-
Recommend Topics
-
javascript
JavaScript (JS) is a lightweight interpreted programming language with first-class functions.
-
web
Some thing interesting about web. New door for the world.
-
server
A server is a program made to process requests and deliver data to clients.
-
Machine learning
Machine learning is a way of modeling and interpreting data that allows a piece of software to respond intelligently.
-
Visualization
Some thing interesting about visualization, use data art
-
Game
Some thing interesting about game, make everyone happy.
Recommend Org
-
Facebook
We are working to build community through open source technology. NB: members must have two-factor auth.
-
Microsoft
Open source projects and samples from Microsoft.
-
Google
Google ❤️ Open Source for everyone.
-
Alibaba
Alibaba Open Source for everyone
-
D3
Data-Driven Documents codes.
-
Tencent
China tencent open source team.
from astyanax.